背景:FLINK CDC 监控多表,通过 Flink Doris Connector 写入 doris。 根据不同表, 对一个主键模型宽表指定不同的部分列更新。
方案1 :
原生 flink sinkto 导入,测试发现无法多表指定不同的部分列更新。
方案2 :
改造sinkto,通过单个streamload 导入, 导入速度很慢。
方案3 :
多个sinkto ,无法导入保证顺序。
请问在这种场景下,有什么好的特性功能,解决方案吗?
背景:FLINK CDC 监控多表,通过 Flink Doris Connector 写入 doris。 根据不同表, 对一个主键模型宽表指定不同的部分列更新。
方案1 :
原生 flink sinkto 导入,测试发现无法多表指定不同的部分列更新。
方案2 :
改造sinkto,通过单个streamload 导入, 导入速度很慢。
方案3 :
多个sinkto ,无法导入保证顺序。
请问在这种场景下,有什么好的特性功能,解决方案吗?