关于老版本cdh兼容性问题

Flink版本：1.15.0 Hive版本：1.1.0-cdh5.15.1 问题描述： java.lang.NullPointerException at org.apache.flink.table.catalog.hive.client.HiveShimV100.registerTemporaryFunction(HiveShimV100.java:422) at org.apache.flink.table.planner.delegation.hive.HiveParser.parse(HiveParser.java:207)

flink sql lateral table问题

关于行转列问题，请教一下 SELECT alert_id, organization_id FROM ( SELECT alert_id, org_ids FROM db_ods_hive.ods_alert_content_in_hive WHERE cd_date = '${date}' ) LEFT JOIN LATERAL TABLE(ALERT_ORGANIZATION_IDS_TO_ROWS(org_ids, ',')) AS T(organization_id) ON TRUE WHERE organization_id IS NOT

flink sql LATERAL TABLE

请教一下，flink sql，lateral table如何配合insert overwrite使用，直接select不报错，但是一旦insert overwrite就报错

flink cdc时间问题

关于cdc有个问题，求大佬能否解释下，是解析bin log的bug还是自己代码bug； mysql数据库中表，创建时间和修改时间设置为current_timestamp 场景一：插入数据 插入数据时忽略创建时间和修改时间字段 cdc接入后，转存到hbase中，转为字符串时间，时间少8个小时 确认了，程序运行的服务器时间、mysql服务器的时间，和hbase服务器的时间，均为UTC+0800时区 场景二：重启服务，重新读取数据 此时cdc接入数据，会将最后的数据拿出来写入hbase，此时按照同样的执行，数据库时间也是放的正确时间，hbase时间也能吻合

flink1.11 elasticsearch connector

elasticsearch7.6有账号认证，目前flink1.11 elasticsearch connector sql api如何加入账号认证？