帮忙发下完整的sink代码
确认下集群是起来的吗?端口都是存活的吗?
这个是warn的日志,可以忽略,数据应该是写入进去了,可以看下表里面的数据,这块没有打印日志信息。
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就可以
