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

我用官网的cdc代码进行测试,Flink cdc 消费不到 MySQL 中的数据。也不报错,程序也不

我用官网的cdc代码进行测试,Flink cdc 消费不到 MySQL 中的数据。也不报错,程序也不会停止。网上有人说要禁用jdk下的安全协议,我照做了,还是不行。有大佬指点一下吗? 1、确定 MySQL binlog 已开启。 2、账号权限已升级到root。瑶瑶

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

有大佬做native flink on k8s的部署方案吗,按照官网的配置,报这种异常,大佬帮忙瞅瞅

有大佬做native flink on k8s的部署方案吗,按照官网的配置,报这种异常,大佬帮忙瞅瞅

问答 2022-09-02 来自:开发者社区

flink sql,1.14以后怎么流join mysql呢 官网文档显示不支持join了?

flink sql,1.14以后怎么流join mysql呢 官网文档显示不支持join了?

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

官网DOCKER部署FLINK 启动TASKMANAGER报错.这个如何解决呢?

官网DOCKER部署FLINK 启动TASKMANAGER报错.这个如何解决呢?

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

flink 1.15.1版本,cdc可以选择什么版本?这个应该是cdc的官网还没把1.15的更新上去

flink 1.15.1版本,cdc可以选择什么版本?这个应该是cdc的官网还没把1.15的更新上去

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

flink 1.15.0 hive 1.2.2 官网写着支持的 按照官网说了放了antlr-run

flink 1.15.0 hive 1.2.2 官网写着支持的 按照官网说了放了antlr-runtime-3.5.2的jar包 这个jar包不是hive1的在2以后的版本 我另外下了个2.3.9的hive 把这个jar包放到了flink 的lib下 但还是无法使用方言。怎么回事?

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

各位大佬,请教下flink sink到oss按官网上的报找不到endpoint,我要想在idea中运

各位大佬,请教下flink sink到oss按官网上的报找不到endpoint,我要想在idea中运行,该怎么在代码中设置oss的endpoint accessKeyId accessKeySecret

问答 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....

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

这一段官网例子,但是用scala 写报错,是不是scala问题呢,scala是2.11的,flink

这一段官网例子,但是用scala 写报错,是不是scala问题呢,scala是2.11的,flink是1.13.5,cdc是2.20,有没有大神看看

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

有人搞过Flink1.14版本 集成Hive-2.1.1-cdh6.3.2版本吗,我按照官网操作,最

有人搞过Flink1.14版本 集成Hive-2.1.1-cdh6.3.2版本吗,我按照官网操作,最后在sql client中创建catalog报错,提示 Unrecognized Hadoop major version number: 3.0.0-cdh6.3.2,怎么办?

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

产品推荐

阿里云实时计算Flink

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

+关注