Apache Doris 中文技术论坛
Questions Tags Users Badges

Flink批处理从doris里读数据然后写到Doris里另外一个表里,但是原始表4亿数据,写了4千万数据就finished了

Asked Dec 23, 2024 Modified Jan 1, 0001
Viewed 77
storage catalog 2.0

Flink批处理从doris里读数据然后写到Doris里另外一个表里,但是原始表4亿数据,写了4千万数据就finished了,两个表均为unique模型,使用的是同一个字段作为主键,使用table api方式,insert into select from,在原表基础上做了case处理,没有任何报错信息,flink版本1.18,Doris版本2.0.11

edited Jan 1, 0001
tzwyx1
asked Dec 23, 2024
1 Answers

读取和写入是用的flink-doris-connector不,以及sink过程中是否有开启严格模式。

edited Jan 1, 1970
张彬华7698
answered Dec 23, 2024
Related Questions
使用UNIQUE KEY建表时候,用日期建分区,日期字段不是跟在id后面,一定要列出日期字段前面所有字段才能建分区吗
1 answers
Doris4.0.3 版本 FE无法启动,频繁报:wait catalog to be ready. feType:UNKNOWN isReady:false
1 answers
版本4.0.4,算子罗盘留下了一堆空目录
2 answers
Doris4.0.2版本,集群部署模式3台主机,不稳定,经常报错。insert报failed to write enough replicas 0/1 for tablet,select查询也报错
1 answers
java jdbc操作事务失败
1 answers
doris 4.0.1 存算分离数据回收求教
1 answers

Terms of service Privacy policy

Powered by Answer - the open-source software that powers Q&A communities.
Made with love © 2026 Apache Doris 中文技术论坛.