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

各位大佬,Flink CDC中动态加表是不是要在全量模式的checkpoint下才能加啊?

各位大佬,Flink CDC中动态加表是不是要在全量模式的checkpoint下才能加啊?

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

flink cdc initial 模式, source表数据量过大,导致checkpoint 一?

flink cdc initial 模式, source表数据量过大,导致checkpoint 一直 Checkpoint expired before completing. 有没有遇到过的大神指导一下如何优化呀?

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

flink Standalone-HA模式,当运行中的taskmanager宕机或被误杀后,

flink Standalone-HA模式,当运行中的taskmanager宕机或被误杀后,导致整个作业挂了。 想问下,有没有办法当taskmanager宕机或被误杀后, JobManager 有没有办法将宕机掉taskmanager,进行重新分配到新的机器上, 保证作业正常运行,而不是让作业挂了

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

大佬们,Flink CDC中用kafka 的ogg-json模式,读出来怎么都是空的呢?

大佬们,Flink CDC中用kafka 的ogg-json模式,读出来怎么都是空的呢?

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

Flink CDC中Oracle 主从模式的话是不是只能监听主库?

Flink CDC中Oracle 主从模式的话是不是只能监听主库?

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

Flink CDC yarn提交模式有大佬遇到这个问题吗?

Flink CDC yarn提交模式有大佬遇到这个问题吗?

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

Flink中yarn-application 模式 可以把多个任务提交到一个集群里吗 有没有提交命?

Flink中yarn-application 模式 可以把多个任务提交到一个集群里吗 有没有提交命令的样例可以参考下

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

Flink CDC中mysql cdc只支持init 和latest两种模式吗?我看源码里就这两种,

Flink CDC中mysql cdc只支持init 和latest两种模式吗?我看源码里就这两种,其余的抛异常

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

Flink CDC on yarn时,代码里使用了kafka producer,如果用模式提交,会?

Flink CDC on yarn时,代码里使用了kafka producer,如果用application模式提交,会遇到StringDeserializer not found的问题,如果用per-job模式提交就正常,这是啥情况?

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

大佬们,想请教个问题我Flink CDC代码以模式读取最新的binlog,挂掉之后想通过的方式进行?

大佬们,想请教个问题我Flink CDC代码以startupOptions(StartupOptions.latest())模式读取最新的binlog,挂掉之后想通过savepoint的方式进行断点续传的话,需要将lastest()改成initial()么?

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

产品推荐

实时计算 Flink

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

+关注