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

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

Asked Dec 23, 2024 Modified Jan 1, 0001
Viewed 69
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
张彬华7688
answered Dec 23, 2024
Related Questions
在kettle中执行insert into select unqie表 提示未指定的列名Column 'dw_createtime' in field list is ambiguous
1 answers
DorisV2.1.3 建表语句分区字段显示<slot 52>
1 answers
Doris 4.0.1 自动分区
1 answers
如何降低doris远程存储的访问频率
1 answers
unique 表类型, 不分区的情况下, 如果给数据设置ttl
1 answers
已经创建的自动分区表无法读取fe配置中修改过的autobucket_max_buckets,导致自动分区表的新分区无法按照fe的新配置自动调整buckets
3 answers

Terms of service Privacy policy

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