flink程序运行几个小时就挂掉了,这个应该往哪个方向排查?

有没有人遇到这个问题? Container released on a lost nodeflink程序运行几个小时就挂掉了,这个应该往哪个方向排查?

Flink程序运行 initializing to running之后就没日志了是什么原因?

Flink程序运行 initializing to running之后就没日志了是什么原因?

实时数据分析:使用Flink实时发现最热Github项目

1 课时 |
404 人已学 |
免费

实时数据接入:5分钟上手 Flink MySQL 连接器

1 课时 |
204 人已学 |
免费

大数据知识图谱系列—基于ELK+Flink日志全观测最佳实践

1 课时 |
174 人已学 |
免费
开发者课程背景图

请教一个flink的问题,我程序运行这偶尔就会报这个错,能帮忙解决一下这个问题吗?

我程序运行这偶尔就会报这个错,能帮忙解决一下这个问题吗?

flink使用RocksDB增量checkpoints,程序运行一段时间报出:超出物理内存怎么处理?

最近刚刚尝试使用flink 1.9.1 的RocksDB做增量checkpoints; 在程序种设置: val backend = new RocksDBStateBackend("hdfs://xx/", true) backend.setPredefinedOptions(PredefinedO...

flink使用RocksDB增量checkpoints,程序运行一段时间报出:超出物理内存

这面还想多请教一下: 我程序中每来一条数据都会去读MapState然后覆盖写入新的时间戳,刚刚发现某一条数据读出了两条一样的时间戳,我推断是第一个线程读出来后还没等覆盖掉,第二个线程又读了一遍,导致出现两条一样的时间戳; 所以想请问flink中MapState是线程安全的吗? *来自志愿者整理的fl...

在flink程序运行过程中加载自定义jar执行其中的function,请问各位大神这个怎#Flink

在flink程序运行过程中加载自定义jar执行其中的function,请问各位大神这个怎么实现 #Flink

使用yarnsession 提交flink程序运行,flink会自己莫名其妙挂掉

2018-10-31 10:02:37,053 WARN akka.remote.ReliableDeliverySupervisor - Association with remote system [akka.tcp://flink@bigdata03:42924] has failed, ad...

请教一下,Standalone的Flink程序运行的时候出OOM了,想DUMP出堆日志来看,请问在Flink里面怎么做类似于HeapDumpOnOutOfMemoryError 的事情?

转自钉钉群21789141:请教一下,Standalone的Flink程序运行的时候出OOM了,想DUMP出堆日志来看,请问在Flink里面怎么做类似于HeapDumpOnOutOfMemoryError 的事情?./flink run /Users/test/project/FlinkSample...

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

产品推荐

热门帮助文档

社区圈子

阿里云实时计算Flink
阿里云实时计算Flink
一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。
199201+人已加入
加入
相关电子书
更多
基于 Flink SQL + Paimon 构建流式湖仓新方
基于 Flink CDC 打造 企业级实时数据集成方案
李劲松|Flink Table Store 典型应用场景
立即下载 立即下载 立即下载