starrocks的sink报错,求解

帮忙发下完整的sink代码

确认下集群是起来的吗?端口都是存活的吗?

这个是warn的日志,可以忽略,数据应该是写入进去了,可以看下表里面的数据,这块没有打印日志信息。

请问下为啥要代码实现这块呢?是flink-cdcd之后的数据做一些复杂etl吗?如果没有复杂etl,可以使用smt+flink-cdc通过flinkl-sql实现,具体可参考 mysql cdc

1.目前smt是一个表会起一个job,多个表同步需要咱们利用flink-connector的stream api写入starrocks,cdc多表写入到starrocks的思路是source按cdc配置读取多表,mapfunc转化成StarRocksSinkRowDataWithMeta,然后写入到sr sink
2.读取binlog也是看job的数量的来决定读取多少次
3.smt只是帮助创建flink sql job,停止恢复还是利用的flink ckp的机制,开启ckp就可以

csv和json都支持