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

Flink CDC中如果增量有延迟的话,通过增加任务的并发数能解决问题吗?

Flink CDC中如果增量有延迟的话,通过增加任务的并发数能解决问题吗?

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

Flink CDC 中streampark提交的任务总是会执行两遍,怎么办?

Flink CDC 中streampark提交的任务总是会执行两遍,怎么办?

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

有一个问题,我可以如何确认Flink CDC任务消费 binlog 的延迟呢?就像 kafka 的

问题1:有一个问题,我可以如何确认Flink CDC任务消费 binlog 的延迟呢?就像 kafka 的 lag一样?大家有什么方法么?这个的确可以。 问题2:这个是看 debezium 的指标么?

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

大佬们 假如我A任务 用Flink CDC读取C这张表 B任务也cdc读取了C 这样会不会有问题?

问题1:大佬们 假如我A任务 用Flink CDC读取C这张表 B任务也cdc读取了C 这样会不会有问题? 问题2:server-id怎么指定

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

大佬们,有个Flink CDC问题。我提交一个计算总数的任务,然后算完以后,又重新开始计算?

大佬们,有个Flink CDC问题。我提交一个计算总数的任务,然后算完以后,又重新开始计算? 一直在循环算

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

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

产品推荐

阿里云实时计算Flink

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

+关注