问答 2023-09-20 来自:开发者社区

Flink CDC使用docker 部署1.17.0版本 使用flinksql报错?

Flink CDC使用docker 部署1.17.0版本 使用flinksql报错,已经加了connector ?

问答 2023-09-07 来自:开发者社区

Flink CDC这个操作在版本切换后出现,oracle数据库无报错,求思路除了初始化改表?

Flink CDC中No metadata registered for captured table 这个操作在版本切换后出现,oracle数据库无报错,求思路除了初始化改表,还可以从哪里查看?

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

Flink运行一个任务,查看版本都是flink 1.13版本有人知道报错这个是为什么吗?

Flink运行一个任务,本地连接远程数据库进行运行时没有问题的,但是部署到服务器后,运行同样的任务,报错 查看版本都是flink 1.13版本有人知道报错这个是为什么吗?

问答 2023-08-28 来自:开发者社区

大佬,Flink CDC 中我使用MySQL cdc 2.2.1版本。遇到这个报错请教下该怎么解决?

问题1:大佬,Flink CDC 中我使用MySQL cdc 2.2.1版本。遇到这个报错请教下该怎么解决呢。我的代码中没有时间转换的代码,感觉像debezium解析的问题?问题2:不是,出现了这个问题,想看看升级到2.4.1版本能不能解决的,但是升到2.4.1版本报这个错误

问答 2023-08-02 来自:开发者社区

大佬们Flink CDC19c版本的oracle同步数据时候报错?请问有没有大哥指点一二?

大佬们Flink CDC19c版本的oracle同步数据时候报错?Caused by: java.sql.SQLException: ORA-44609: CONTINOUS_MINE is desupported for use with DBMS_LOGMNR.START_LOGMNR. ORA-06512: at "SYS.DBMS_LOGMNR",请问有没有大哥指点一二?

问答 2023-07-13 来自:开发者社区

flink 1.14.4版本使用hbase sql connector 报错如何解决呢?

flink 1.14.4版本使用hbase sql connector 报错如何解决呢?

问答 2023-06-04 来自:开发者社区

Flink CDC适配了很多版本,kafka 各种错?这个怎么破?版本是这样的?怎么适配不会报错

Flink CDC适配了很多版本,kafka 各种错?这个怎么破?link SQL> insert into sink_user select * from source_user_kafka; [ERROR] Could not execute SQL statement. Reason: java.lang.NoSuchMethodError: org.apache.flink.tabl...

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

大佬,Flink-CDC-Mongodb有这些包对应的版本吗?换个版本本地就输出不了数据了,也不报错

大佬,Flink-CDC-Mongodb有这些包对应的版本吗?换个版本本地就输出不了数据了,也不报错,使用datastream api,flink是1.13、Mongodb-cdc是2.1.0可以输出数据,Mongodb-cdc换成2.3.0就没数据输出了,也不报错

问答 2023-04-19 来自:开发者社区

flink 是13.6版本照着cdc connector的例子写的直接报错了能帮忙解决一下么?

public class Main { public static void main(String[] args) throws Exception { Properties debeziumProperties = new Properties(); debeziumProperties.put("snapshot.locking.mode", "none");// do n...

问答 2023-03-21 来自:开发者社区

请问flink版本1.16.1,从MysqlSource监听表的流转换为Table,现在报错为什么?

大哥们,flink版本1.16.1,我从MysqlSource监听表的流转换为Table,现在报错 有没有遇到相同问题的?

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

产品推荐

实时计算 Flink

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

+关注