问答 2023-12-29 来自:开发者社区

Flink1.18.0版本连接外部kafka本地执行测试代码报错

版本:Flink1.18.0代码如下:```public static void main(String[] args) { //1、创建TableEnvironment EnvironmentSettings settings = EnvironmentSettings.newInstance().build(); TableEnvironment tEnv = Tab...

问答 2023-12-29 来自:开发者社区

Flink1.18.0版本连接外部mysql本地执行测试代码报错

版本:Flink1.18.0 代码:``` public static void main(String[] args) { //1、创建TableEnvironment EnvironmentSettings settings = EnvironmentSettings.newInstance().build(); TableEnvironment tEnv = Tab...

问答 2023-12-05 来自:开发者社区

Flink CDC业务库用的阿里PolarDB,版本5.6.16,但是这个报错怎么解决呢?

Flink CDC业务库用的阿里PolarDB,版本5.6.16,flinkCDC我用的2.4.我看是版本支持的,但是这个报错怎么解决呢?

问答 2023-12-01 来自:开发者社区

Flink CDC 1.17是版本有问题还是时区有问题,时区我改了很多次,报错还是原状?

,oracle-cdc2.4.2 oracle是docker拉的oracle11,我本地跑程序能正常捕获数据,提交到远程flink环境,就报了以下错误Flink CDC 1.17是版本有问题还是时区有问题,时区我改了很多次,报错还是原状?

问答 2023-11-16 来自:开发者社区

Flink CDC2.4版本通过cdc的时间戳方式读取mysql数据不生效也不报错,怎么排查问题?

Flink CDC2.4版本通过cdc的时间戳方式读取mysql数据不生效也不报错,怎么排查问题?1.14采用flinksql建立连接读的,方式和官网的一致,这个用timestamp读取和mysql版本或者配置有关系吗?因为读取过别的mysql又可以成功

问答 2023-11-01 来自:开发者社区

FLink 1.13版本升级Flink 1.17 报错 ,怎么处理?

FLink 1.13版本升级Flink 1.17 报错 ,怎么处理?RpcLoaderException: could not load RpcSystem和这个问题差不多 https://www.saoniuhuo.com/question/detail-2743444.htmlflink-rpc-coreflink-streaming-javaflink-clients这些包 以及其他包多有....

问答 2023-11-01 来自:开发者社区

FLink 1.13版本升级Flink 1.17 报错 ,怎么解决?

FLink 1.13版本升级Flink 1.17 报错 ,怎么解决?RpcLoaderException: could not load RpcSystem 和这个问题差不多 https://www.saoniuhuo.com/question/detail-2743444.htmlflink-rpc-coreflink-streaming-javaflink-clients这些包 以及其他包多....

问答 2023-10-30 来自:开发者社区

Flink 1.13版本升级Flink 1.17 报错 有人知道为什么吗?

Flink 1.13版本升级Flink 1.17 报错 RpcLoaderException: could not load RpcSystem 和这个问题差不多 https://www.saoniuhuo.com/question/detail-2743444.htmlflink-rpc-coreflink-streaming-javaflink-clients这些包 以及其他包多有引入 本地....

问答 2023-10-25 来自:开发者社区

Flink中集成celeborn时,用kyuubi提交spark3.0版本的任务有的报错,怎么处理?

Flink中我在集成celeborn的时候,使用kyuubi提交spark3.0版本的任务有的sql会有报错,100%复现,用命令行提交就没问题,怎么处理?

问答 2023-10-18 来自:开发者社区

flink cdc2.4.1版本连接mysql,运行一段时间后就会报错,这个有修复吗?

flink cdc2.4.1版本连接mysql,运行一段时间后就会报错,这个有修复吗,有可能binlog发生轮换了?The connector is trying to read binlog starting at Struct{version=1.9.7.Final,connector=mysql,name=mysql_binlog_source,ts_ms=1696934695426,db....

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

实时计算 Flink

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

+关注