问答 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 任务取消中如何强制停止呢?

文章 2023-11-11 来自:开发者社区

将Apache Flink任务实时消费Kafka窗口的计算改为MaxCompute

将Apache Flink任务实时消费Kafka窗口的计算改为MaxCompute,需要经过以下几个步骤: 数据接入:首先,你需要将Flink任务产生的数据写入到MaxCompute。这可以通过Flink的DataStream API中的sink函数来实现。你可以选择将数据写入到MaxCompute的表或者分区。 数据处理:在...

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

flink启动任务,taskmanager.out 文件增涨非常快,这个文件大小怎么限定?

flink启动任务,taskmanager.out 文件增涨非常快,这个文件大小怎么限定?测试了很多办法发现都不起作用

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

Flink这个任务总是lost leadership 报这个错误之前 总有chk失败,怎么解决?

Flink这个任务 总是lost leadership 报这个错误之前 总有chk失败,怎么解决?失败的算子是 sql聚合运算

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

Flink非常简单的kafka2kafka任务报这个错;这个错一般什么原因引起的?

Flink非常简单的kafka2kafka任务报这个错;这个错一般什么原因引起的?

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

flink1.11 执行任务控制台日志怎么没有 application ID 呀?

flink1.11 执行任务控制台日志怎么没有 application ID 呀?

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

产品推荐

阿里云实时计算Flink

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

+关注