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

请教个问题,我从mysql-cdc 到Kafka,报错,版本是flink 1.13.6 cdc版

请教个问题,我从mysql-cdc 到Kafka,报错,版本是flink 1.13.6 cdc版

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

大佬们请教个问题,15.2版本flink-conf 里配置了 high-availability.

大佬们请教个问题,15.2版本flink-conf 里配置了 high-availability.zookeeper.path.root: /flink,yarn-per-job 提交任务的时候包这个错误,org.apache.flink.client.program.ProgramInvocationException: The main method caused an error: Cou....

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

请教个问题,Dinky 0.6.6版本兼容flink 1.14吗? flink1.14各种报错,看起

请教个问题,Dinky 0.6.6版本兼容flink 1.14吗? flink1.14各种报错,看起来应该是jar包冲突之类的,flink1.13部署的就很通畅

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

有没有大佬接mysql全量数据时候报这个错,用的jar包版本是这个:flink-sql-connec

有没有大佬接mysql全量数据时候报这个错,用的jar包版本是这个:flink-sql-connector-mysql-cdc-2.2.0.jar,taskmanager内存给的也不小,但这个问题出现频率挺高的,怎么办?

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

各位有遇到过这个错误的吗?依赖版本:flink 1.14.5flink-connector-mysq

各位有遇到过这个错误的吗?依赖版本:flink 1.14.5flink-connector-mysql-cdc 2.2.0flink-connector-debezium 2.2.0flink-sql-connector-mysql-cdc 2.2.0,怎么办?

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

有谁知道哪个版本的flink cdc 既支持startupoptions.specificoffse

有谁知道哪个版本的flink cdc 既支持startupoptions.specificoffset,又支持获取schemachanges?

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

大佬们,咨询下 FlinkCDC支持oracle的版本是基于Flink的哪个版本实现的

大佬们,咨询下 FlinkCDC支持oracle的版本是基于Flink的哪个版本实现的

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

各位社区大佬, Flink-1.13.6版本的 Flink cdc提交到yarn上,以yarn se

各位社区大佬, Flink-1.13.6版本的 Flink cdc提交到yarn上,以yarn session 模式运行,如果禁用托管内存呢

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

Flink-1.13.6版本的 Flink sql以yarn session 模式运行,怎么禁用托管

Flink-1.13.6版本的 Flink sql以yarn session 模式运行,怎么禁用托管内存啊,尝试了flink-conf配置,也尝试了 sql-client提交时设置,但都不生效。哪位大佬知道怎么禁用托管内存啊

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

请问,1.10.2版本的flink有没有状态初始化的功能,就是要初始化一批数据到状态里,然后再开始消

请问,1.10.2版本的flink有没有状态初始化的功能,就是要初始化一批数据到状态里,然后再开始消费kafka?

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

产品推荐

实时计算 Flink

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

+关注