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

flink cdc 任务启动后加表读binlog报错有人碰到没?

flink cdc 任务启动后加表读binlog报错有人碰到没?2023-11-09 19:30:05,620 ERROR io.debezium.connector.mysql.MySqlStreamingChangeEventSource [] - Error during binlog processing. Last offset stored = {transaction_id=nu.....

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

Flink CDC从savepoint重启后会有这个error日志,但是flink任务没有异常重启?

Flink CDC从savepoint重启后会有这个error日志,但是flink任务没有异常重启,这是正常日志?

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

Flink CDC用cdc版本2.4的话 任务起不来 一直ctreated状态?

Flink CDC是1.15的emr 阿里的半托管, 用cdc版本2.4的话 任务起不来 一直ctreated状态?

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

在Flink我这样创建的水印,但是任务运行的时候报错怎么处理?

在Flink我这样创建的水印,但是任务运行的时候报错怎么处理? timestamp是bigint型, 单位秒,我也这么改过, 但是问题还是存在,没有解决。

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

Flink的mysql cdc指定时间戳读取读不到数据,任务自动重启之后,新数据也读不到。怎么解决?

Flink的mysql cdc指定时间戳读取读不到数据,任务自动重启之后,新数据也读不到。怎么解决?

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

Flink双流join任务使用checkpoint恢复失败,怎么处理?

Flink双流join任务使用checkpoint恢复失败,怎么处理?现象:找不到文件错误:Caused by: java.io.FileNotFoundException: /data1/flink/checkpoint/xxx/checkpoint2/d5d14dd3d0731cc46fa8f80b37d75577/chk-5/2c17a70a-b189-40c3-8c5d-e9581651....

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

Flink这些完成的任务怎么删除呢?

Flink这些完成的任务怎么删除呢?

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

Flink CDC会出现分配和之前任务相同的是吗?

Flink CDC任务指定了server-id后面在启动别的cdc任务但是没有指定server-id可能会导致新的任务去随机分配server-id的时候,会出现分配和之前任务相同的是吗?

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

我现在在机器学习PAI的集群上提交了包含alink相关功能的flink任务,但是却报这样的错。

我现在在集群上提交了包含alink相关功能的flink任务,但是却报这样的错。我在idea上跑是没问题的,而且也去除了log4j相关的依赖。 有没有大佬碰见过这样的问题的?我服务器上的flink是用docker启的,和本地的flink版本都是1.9.0

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

Flink cancel 任务取消中如何强制停止呢?

Flink cancel 任务取消中如何强制停止呢?

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

产品推荐

阿里云实时计算Flink

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

+关注