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

Flink CDC中用 SQL 方式配置 Flink CDC 任务,同一个 Job 中声明了多张表?

Flink CDC中用 SQL 方式配置 Flink CDC 任务,同一个 Job 中声明了多张表,最后任务提交后发现 MySQL 侧是多次订阅,这种场景有什么好的解决方案吗,保证 MySQL 侧只订阅一次?

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

问一下大佬们 Flink CDC中我从checkpoint 指定进行任务恢复 在代码里面这么?

问题1:问一下大佬们 Flink CDC中我从checkpoint 指定进行任务恢复 在代码里面这么配置不生效 是不是配置有问题, 我用启动命令 -s 指定路劲就有效 在代码里面就无效 是我指定的代码配置有问题吗? 问题2:scala 好像没有这个方法 只有一个无参的方法,是我导错包了

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

各位大佬,请问一下Flink CDC中mysql cdc ,任务失败后,从checkpoint 重?

各位大佬,请问一下Flink CDC中mysql cdc ,任务失败后,从checkpoint 重启失败,报了一个文件找不到的异常,又遇到过的吗? 这个问题之前也出现过,我之前还以为是我直接stop容器导致checkpoint的文件不完整的原因。这次是job直接失败了,然后也无法重启

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

请教下,Flink中一个任务的输入依赖于前面两个任务的输出,三个任务都是独立的。应该怎么做?

请教下,Flink中一个任务的输入依赖于前面两个任务的输出,三个任务都是独立的。应该怎么做?

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

求助,Flink CDC 之前yarn session 上了二十多个SQL任务。一次新提交一个任务?

求助,Flink CDC 之前yarn session 上了二十多个SQL任务。一次新提交一个任务,估计是AM资源紧张,一直在提交尝试中。后来就出事故了,网络带宽占满,被数据中心人员找了过来。一看YARN SESSION中的所有的JOB都在initing 中,把任务停掉就降下来了。这种情况帮忙分析一下,是怎么产生的,要如何才能避免呢?动不动就占满带宽影响太大了。所有的CDC表都是latest 启....

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

大佬们,Flink CDC中oraclecdc 在写入数据的时候,如果多个任务往一张表里写会报错,?

大佬们,Flink CDC中oraclecdc 在写入数据的时候,如果多个任务往一张表里写会报错,这个有解决办法吗?

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

请问Flink CDC中,我kudu作为source,每执行一次任务,jobmanager的句柄就会

请问Flink CDC中,我kudu作为source,每执行一次任务,jobmanager的句柄就会增加,导致时间长了系统挂掉,句柄超过65535,这个是怎么回事呢?

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

影响 flink去check point 的因素有哪些呢?我们的任务今天在疯狂,原来设定30分钟,

影响 flink去check point 的因素有哪些呢?我们的任务今天在疯狂checkpoint ,原来设定30分钟,现在快的一两分钟,两三分一次

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

Flink 中有MySQL cdc 的大佬吗,我有一个任务读快照数据的时候,读到某一个表,然后没有?

问题1:Flink 中有MySQL cdc 的大佬吗,我有一个任务读快照数据的时候,读到某一个表,然后没有读到,也没有继续读其他的表,然后持续了有半小时以上了 问题2:是说我这个问题吗?这个是一开始启动一直运行的时候出的问题,然后从 checkpoint 重启以后也没有读到数据,甚至从jobmanager 日志中都找不到add split 相关的信息 我这个是2.3版本

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

大佬,我用的flink on k8s standalone 配置的高可用任务失败后自动重启没有从?

大佬,我用的flink on k8s standalone 配置的高可用任务失败后自动重启没有从checkpoint处启动呢,而是直接重新启动了呢?可以提供下思路嘛?

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

产品推荐

实时计算 Flink

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

+关注