问答 2025-05-06 来自:开发者社区

flink用rocksdb作为状态后端,taskmanager重启后rocksdb目录文件会被清空

flink使用rocksdb作为状态后端,当taskmanager重启后,rocksdb中的文件会被清空,是正常的吗?flink.conf关键配置如下: execution.checkpointing.externalized-checkpoint-retention: RETAIN_ON_CANCELLATIONexecution.checkpointing.max-concurrent-ch....

文章 2024-03-28 来自:开发者社区

在Rancher K8s上部署Flink时,TaskManager连接不上并不断重启可能是由多种原因导致的

在Rancher K8s上部署Flink时,TaskManager连接不上并不断重启可能是由多种原因导致的。以下是一些可能的解决方案: 检查Pod的网络策略:确保Kubernetes集群中的网络策略允许TaskManager Pod与其他Pod通信。如果没有正确的网络策略,TaskManager可能无法连接到JobManager或其他Tas...

文章 2024-03-07 来自:开发者社区

Flink任务管理器(TaskManager)在凌晨重启,可能是由于以下几种原因

Flink凌晨的时候有些tm重启是什么原因?2023-12-2504:46:59,783ERRORorg.apache.flink.runtime.taskexecutor.TaskManagerRunner [-Fatal error occurred while executing the TaskManager. Shutting it dow..at java...

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

产品推荐

阿里云实时计算Flink

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

+关注