ogg数据导入到kafka ,通过flink sql 导入starrock ,任务正常执行,starrocks中没有数据

【详述】ogg数据导入到kafka ,通过flink sql 导入starrock ,任务正常执行,starrocks中没有数据
【背景】oracle ->ogg-》kafka -> flink sql -> starrock?
【业务影响】
【StarRocks版本】例如:1.18.2
【集群规模】例如:3fe(1 follower+2observer)+5be(fe与be混部)
【机器信息】CPU虚拟核/内存/网卡,例如:48C/64G/万兆
【附件】

  • fe.warn.log/be.warn.log/相应截图
  • 慢查询:
    • Profile信息
    • 并行度:show variables like ‘%parallel_fragment_exec_instance_num%’;
    • cbo是否开启:show variables like ‘%cbo%’;
    • be节点cpu和内存使用率截图

主键模型现在不支持flink的方式导入吗

当前支持的,ogg同步过来的数据当前需要自己实现中间的语义转换,比如ogg同步过来的update、delete这种数据。正在做flink-cdc方式实现从oracle实时同步到starrocks,可以期待下。

为啥我现在任务正常执行 但是在starrocks里面查不到数据