问答 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处启动呢,而是直接重新启动了呢?可以提供下思路嘛?

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

请问flink提交作业的时候可以共用一个jar包,根据不同的配置参数来创建不同的任务吗?

请问flink提交作业的时候可以共用一个jar包,根据不同的配置参数来创建不同的任务吗?

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

请教大佬一个关于flink的问题:我单机版任务失败,我如何确保是从失败的时间 重新消费增量数据?

请教大佬一个关于flink的问题:我单机版任务失败,我如何确保是从失败的时间 重新消费增量数据?

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

Flink CDC中oracle 19c不知道支持怎么样,但如果log日志过大的话会出现任务失败的?

问题1:Flink CDC中oracle 19c不知道支持怎么样,但如果log日志过大的话会出现任务失败的情况,我们产品是对cdc做了封装的哈是遇到了oracle cdc 同步任务失败的情况,可以仅供参考下 ? 问题2:这样啊,必须改源码吗,有没有什么参数可以控制它内存的呀

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

Flink CDC中sql-client 如何停止任务并设置savepoint呢?

Flink CDC中sql-client 如何停止任务并设置savepoint呢?

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

请问一下,Flink CDC中sql-client.sh,在提交任务的时候,可以指定任务名称吗?

请问一下,Flink CDC中sql-client.sh,在提交任务的时候,可以指定任务名称吗?

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

Flink CDC有办法多台机器同一个任务读取同一个表吗?springboot应用直接用cdc ap

Flink CDC有办法多台机器同一个任务读取同一个表吗?springboot应用直接用cdc api读取的

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

产品推荐

阿里云实时计算Flink

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

+关注