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

大佬,我用flink sql的形式用cdc,在运行,不报错,也不打印在控制台怎么办?![image.

大佬,我用flink sql的形式用cdc,在运行,不报错,也不打印在控制台怎么办? 这个问题,要怎么排查 打印了,用datastream的形式,能读到数据,我要上传jar包,运行到yarn,一直做同步,其实都一样,这个应该不是数据库的问题,因为datastream可以读,DataStream resultStream = tableEnv.toChangelogStream(resultTab....

阿里云文档 2023-05-01

Dataphin如何解决使用Flink脚本任务运行报SQL语法错误

问题描述Dataphin使用Flink脚本任务运行报SQL语法错误。解决方案Dataphin Flink SQL中不支持DDL建表语法,CREATE建表需要使用创建元表的方式代替。适用于Dataphin

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

使用flink1.14.0 使用mongo connector 2.3 运行sql语句报错提示,咋办

使用flink1.14.0 使用mongo connector 2.3 运行sql语句报错提示,咋办

问答 2022-12-27 来自:开发者社区

flink打包后运行出现这个报错:Caused by: org.apache.flink.table

flink打包后运行出现这个报错:Caused by: org.apache.flink.table.api.ValidationException: Cannot discover a connector using option: 'connector'='postgres-cdc'

问答 2022-12-19 来自:开发者社区

实时计算Flink本地运行正常提交到控制台报错

实时计算Flink本地运行正常提交到控制台报错

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

Flink CDC 大佬们 mysqlcdc写doris 扒的官网 运行之后报错 不

Flink CDC 大佬们 mysqlcdc写doris 扒的官网 运行之后报错 不知道为何 能帮忙看一下吗?

问答 2022-12-04 来自:开发者社区

Flink CDC 大佬们,cdc2.2.1采集oracle 19c时程序能运行,又不报错,但是拉取

Flink CDC 大佬们,cdc2.2.1采集oracle 19c时程序能运行,又不报错,但是拉取不到数据是怎么回事呀?

问答 2022-11-27 来自:开发者社区

大佬们,我打成jar包之后,上传到flink上面运行报错,能帮忙看看吗?

java.util.concurrent.CompletionException: org.apache.flink.client.program.ProgramInvocationException: The program's entry point class 'com.kuke.flinkcdc.MysqlDataStreamJob' could not be loaded due to....

问答 2022-08-10 来自:开发者社区

大佬们我想问一下,为什么情况一flink程序可以正常运行而2情况用in方式就会报错啊

大佬们我想问一下,为什么情况一flink程序可以正常运行而2情况用in方式就会报错啊

问答 2022-07-25 来自:开发者社区

Flink CDC 2.2.1版本按官网Demo运行报错

Jar包依赖: 1.13.6 1.0.7-SNAPSHOT 1.4-SNAPSHOT 2.2.1 1.5.4.Final 1.12.0 主程序见下图: 全量数据可以正常输出,增量数据报错。 报错如下: java.lang.RuntimeException: One or more fetchers have encountered exception at org.apache....

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

产品推荐

阿里云实时计算Flink

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

+关注
AI助理

你好,我是AI助理

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

登录插画

登录以查看您的控制台资源

管理云资源
状态一览
快捷访问