问答 2024-08-26 来自:开发者社区

flink1.1.6 hadoop版本3.0.0 ,但是跑cdc作业时出现这个报错 怎么解决?

有无大佬帮忙看下,flink1.1.6 hadoop版本3.0.0 ,在yarn上是运行flink测试程序时可以正常跑的,但是跑cdc作业时出现这个报错

问答 2024-06-26 来自:开发者社区

在Flink CDC中flink版本1.15,写入kafka报错,如何解决?

在Flink CDC中flink版本1.15,写入kafka报错,如何解决?请参考图片:

问答 2024-06-12 来自:开发者社区

在Flink CDC中cdc版本2.3 OracleCDC 当日志归档删除以后任务报错怎么处理?

在Flink CDC中cdc版本2.3 OracleCDC 用的Logminer模式 当日志归档删除以后 任务报错怎么处理?

问答 2024-06-12 来自:开发者社区

在Flink CDC中cdc 3.1的版本 从mysql 读的时候报错,如何解决?

在Flink CDC中cdc 3.1的版本 从mysql 读的时候报错,如何解决?请参考图片:

问答 2024-06-05 来自:开发者社区

在Flink CDC中cdc 3.1的版本 从mysql写入到paimon报错,如何解决?

在Flink CDC中cdc 3.1的版本 从mysql写入到paimon报错,如何解决?请参考图片:

问答 2024-05-22 来自:开发者社区

使用flink cdc 3最新版本,想通过mysql同步到别的mysql,但是发现报错

用的连接器:flink-cdc-pipeline-connector-mysql-3.0.1.jar 运行后提示 [root@bogon flink-cdc-3.0.0]# bin/flink-cdc.sh mysql-to-mysql.yamlException in thread "main" java.lang.RuntimeException: Cannot find factory .....

问答 2024-05-20 来自:开发者社区

Flink CDC里我这边使用的是cdc3.0版本 发现sqlserver数据库新增字段后作业报错?

Flink CDC里我这边使用的是cdc3.0版本 发现sqlserver数据库新增字段后作业就会报错是什么原因呀 ? 之前的版本不会。我这边提交不了 没有账号的 申请被拒绝了。

问答 2024-04-15 来自:开发者社区

Flink CDC里我使用3.0的版本 flink1.18版本(官网示例使用版本)启动任务报错咋办?

Flink CDC里使用3.0的版本 flink1.18版本(官网示例使用版本)启动cdc3.0同步mysql 2 doris的任务报错,怎么解决?

问答 2024-03-05 来自:开发者社区

Flink CDC版本1.15.0,mongocdc版本2.2.1,flinksql同步报错,为啥?

Flink CDC版本1.15.0,mongocdc版本2.2.1,mongodb版本3.6.18,flinksql同步报错?Command failed with error 40415 (Location40415): 'BSON field '$changeStream.allChangesForCluster' is an unknown field.'

问答 2024-01-31 来自:开发者社区

flink vvp版本报错是不是版本不支持?

flink中,上游是msyql 下游是maxcomputer的Transaction Table2.0 ,就是部署就报错,但是latest-offset设置这个可以,earliest-offset这个就不行,是因为不支持这个vvp 版本吗? Unable to create a source for reading table 'lj-orange.orange.chargeorder'.T...

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

产品推荐

阿里云实时计算Flink

一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。

+关注
AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等