这个问题主要的原因是作业已经运行完了，解决方法就是在作业处理方法里面（run回调方法）加一个while死循环，让Flink程序识别作业没有跑完即可。
解决Flink Checkpoint snapshotState方法无法回调的问题
2023-11-20
66
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《
阿里云开发者社区用户服务协议》和
《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写
侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
本文涉及的产品
简介：
解决Flink Checkpoint snapshotState方法无法回调的问题
目录
相关文章
|
4月前
|
容灾
流计算
|
4月前
|
消息中间件
监控
Java
实时计算 Flink版产品使用问题之该如何解决checkpoint频繁失败
实时计算Flink版作为一种强大的流处理和批处理统一的计算框架，广泛应用于各种需要实时数据处理和分析的场景。实时计算Flink版通常结合SQL接口、DataStream API、以及与上下游数据源和存储系统的丰富连接器，提供了一套全面的解决方案，以应对各种实时计算需求。其低延迟、高吞吐、容错性强的特点，使其成为众多企业和组织实时数据处理首选的技术平台。以下是实时计算Flink版的一些典型使用合集。
63
0
0
|
2月前
|
SQL
消息中间件
分布式计算
大数据-115 - Flink DataStream Transformation 多个函数方法 FlatMap Window Aggregations Reduce
大数据-115 - Flink DataStream Transformation 多个函数方法 FlatMap Window Aggregations Reduce
37
0
0
|
4月前
|
容灾
流计算
美团 Flink 大作业部署问题之Checkpoint 的 metadata 文件包含什么信息
美团 Flink 大作业部署问题之Checkpoint 的 metadata 文件包含什么信息
49
1
1
|
4月前
|
存储
调度
流计算
Flink 新一代流计算和容错问题之如何实现 Generalized Log-Based Incremental Checkpoint
Flink 新一代流计算和容错问题之如何实现 Generalized Log-Based Incremental Checkpoint
38
1
1
|
4月前
|
存储
缓存
数据处理
Flink 新一代流计算和容错问题之中间数据流动缓慢导致 Checkpoint 慢的问题要如何解决
Flink 新一代流计算和容错问题之中间数据流动缓慢导致 Checkpoint 慢的问题要如何解决
46
1
1
|
4月前
|
存储
分布式计算
算法
|
4月前
|
SQL
消息中间件
Kafka
实时计算 Flink版产品使用问题之水位线的设置方法是什么
实时计算Flink版作为一种强大的流处理和批处理统一的计算框架，广泛应用于各种需要实时数据处理和分析的场景。实时计算Flink版通常结合SQL接口、DataStream API、以及与上下游数据源和存储系统的丰富连接器，提供了一套全面的解决方案，以应对各种实时计算需求。其低延迟、高吞吐、容错性强的特点，使其成为众多企业和组织实时数据处理首选的技术平台。以下是实时计算Flink版的一些典型使用合集。
65
1
1
|
4月前
|
关系型数据库
MySQL
数据处理
实时计算 Flink版产品使用问题之mini-cluster模式下，怎么指定checkpoint的时间间隔
实时计算Flink版作为一种强大的流处理和批处理统一的计算框架，广泛应用于各种需要实时数据处理和分析的场景。实时计算Flink版通常结合SQL接口、DataStream API、以及与上下游数据源和存储系统的丰富连接器，提供了一套全面的解决方案，以应对各种实时计算需求。其低延迟、高吞吐、容错性强的特点，使其成为众多企业和组织实时数据处理首选的技术平台。以下是实时计算Flink版的一些典型使用合集。
83
0
0
|
4月前
|
存储
监控
Serverless
Serverless 应用的监控与调试问题之Flink对于Checkpoint Barrier流动缓慢的问题要如何解决
Serverless 应用的监控与调试问题之Flink对于Checkpoint Barrier流动缓慢的问题要如何解决
34
0
0
热门文章
最新文章
1
Flink on YARN（上）：一张图轻松掌握基础架构与启动流程
2
Flink SQL之时态表（Temporal Tables）
3
Flink 消息聚合处理方案
4
Flink---13、容错机制（检查点（保存、恢复、算法、配置）、状态一致性、端到端精确一次）
5
flink 手动维护kafka offset
6
Flink+Hologres实时数仓在Lazada的建设及应用
7
10月17日Spark社区直播【Tablestore Spark Streaming Connector -- 海量结构化数据的实时计算和处理】
8
江铃汽车基于 Flink 构建数据集成平台的设计与实现
9
flink timer定时器
10
大数据技术解析：Hadoop、Spark、Flink和数据湖的对比
1
10分钟了解Flink SQL使用
362
2
基于OceanBase+Flink CDC，云粒智慧实时数仓演进之路
22758
3
Blink实时计算：Explorer大基数表的写入性能优化
93
4
Flink DataStream API 批处理能力演进之路
619
5
人工智能平台PAI 操作报错合集之在集群上提交了包含alink相关功能的flink任务，但是却报错如何解决
100
6
阿里巴巴瓴羊基于 Flink 实时计算的优化和实践
620
7
[尚硅谷flink] 检查点笔记
191
8
[尚硅谷 flink] 状态管理 笔记
77
9
[尚硅谷flink学习笔记] 实战案例TopN 问题
185
10
[尚硅谷 flink] 基于时间的合流——双流联结
83