之前Flink sql 任务使用的connector 版本为1.2.3_flink_1.15 版本。后续将connector 版本升级到1.2.4_flink_1.15 版本。任务重启后报错。
测试后续表名中没有# 号的字段,1.2.4 版本可以正常使用。应该是这个问题
这个问题已经提交了bugfix,下个版本(1.2.6)发布 https://github.com/StarRocks/starrocks-connector-for-apache-flink/pull/173
测试后续表名中没有# 号的字段,1.2.4 版本可以正常使用。应该是这个问题
这个问题已经提交了bugfix,下个版本(1.2.6)发布 https://github.com/StarRocks/starrocks-connector-for-apache-flink/pull/173