问答 2024-03-06 来自:开发者社区

Flink任务怎么实现重启后直接跑最新的任务而不是去根据checkpoint跑历史数据?

Flink任务怎么实现重启后直接跑最新的任务而不是去根据checkpoint跑历史数据?

问答 2024-03-06 来自:开发者社区

如果用Flink cdc 直接接业务数据,我们应该怎么去避免我们下游的计算任务和接入不出问题?

如果用Flink cdc 直接接业务数据,如果突然业务这边要回刷一整年的订单某个一段。这种我们应该怎么去避免我们下游的计算任务和接入不出问题,这个数据量和资源有比例吗?

问答 2024-03-06 来自:开发者社区

Flink CDC一个任务可以同时启动多个Source吧?

Flink CDC一个任务可以同时启动多个Source吧?

问答 2024-03-06 来自:开发者社区

有没有什么设置 可以让Flink CDC感知到断连了 然后自动重启cdc任务?

有没有什么设置 可以让Flink CDC感知到断连了 然后自动重启cdc任务?

问答 2024-03-05 来自:开发者社区

oracle11g cdc3.0 flink1.18 为啥任务启动后要等十多分钟才读到数据?

oracle11g cdc3.0 flink1.18 为啥任务启动后要等十多分钟才读到数据,表里面只有几条数据,有人知道不?

问答 2024-03-05 来自:开发者社区

Flink CDC怎么知道checkpoint是哪个任务的。从路径上看不出来?

Flink CDC怎么知道checkpoint是哪个任务的。从路径上看不出来?

问答 2024-03-05 来自:开发者社区

flink cdc有什么办法判断任务是全量阶段还是增量阶段吗,想做一个监控,但找了圈,没有对应指标?

flink cdc有什么办法判断任务是全量阶段还是增量阶段吗,想做一个监控,但找了圈,没有对应指标?

问答 2024-03-05 来自:开发者社区

Flink 任务卡死,不消费。

1:业务运行一段时间后出现卡死。2:实际下游算子并未出现死锁情况。3:关闭ck后,运行3d未出现。4:增加输入并发压力,出现概率更高,运行30min 左右可能就出现。 线程栈基本都是在wait 状态:{ "threadName": "log-reduce (1/1)#8", "stringifiedThreadInfo": "\"log-reduce ...

问答 2024-03-01 来自:开发者社区

Flink1.18.1和CDC2.4.1 本地没问题,提交任务到服务器报错,下图是报错和全jar包

Flink1.18.1和CDC2.4.1 本地没问题,提交任务到服务器报错,下图是报错和全jar包

问答 2024-03-01 来自:开发者社区

Flink1.18.1和CDC2.4.1 本地没问题 提交任务到服务器 报错

Flink1.18.1和CDC2.4.1 本地没问题 提交任务到服务器 报错java.lang.NoClassDefFoundError: Could not initialize class io.debezium.connector.mysql.MySqlConnectorConfig上面是全部jar包

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

产品推荐

阿里云实时计算Flink

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

+关注