FAQ-实时传输PG-Iceberg时PG表名同时存在大小写报错

问题描述/异常栈
问题症状描述:实时任务PG为源端且表名同时存在大小写时会报错,将flink日志中报错sql拿到自助分析执行。
FAQ-实时传输PG-Iceberg时PG表名同时存在大小写报错 - 图1
org.apache.flink.util.FlinkRuntimeException:Generate Splits for table db.table error
发现版本
EasyData 9.0 up09
解决方案
临时方案:将表名修改为小写
解决方案:升级ED 10.0 up02
问题原因
pg表名是public.ABc,flink查询sql为[SELECT reltuples::bigint FROM pg_class WHERE oid = to_regclass('public.ABc')] 小写查询不到导致报错.
FAQ-实时传输PG-Iceberg时PG表名同时存在大小写报错 - 图2
社区bug: https://issues.apache.org/jira/browse/FLINK-37371

作者:楚展航