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

Viewed 51

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

1 Answers