Flink 多表导入单个宽表部分列更新问题

Viewed 104

背景:FLINK CDC 监控多表,通过 Flink Doris Connector 写入 doris。 根据不同表, 对一个主键模型宽表指定不同的部分列更新。
方案1 :
原生 flink sinkto 导入,测试发现无法多表指定不同的部分列更新。
方案2 :
改造sinkto,通过单个streamload 导入, 导入速度很慢。
方案3 :
多个sinkto ,无法导入保证顺序。

请问在这种场景下,有什么好的特性功能,解决方案吗?

3 Answers

这个可以,非常需要这个

可以在streamload写入的时候,拼接本次要更新的column header。

请问 这个问题有新的解决方法吗