Flink独立集群与hdfs集群不在一起,flink如何配置checkpoint目录为hdfs?

Flink独立集群与hdfs集群不在一起,flink如何配置checkpoint目录为hdfs?

Flink有没有遇到过打checkpoint的时候,遇到写hdfs的错误然后一直卡死,怎么回事?

Flink有没有遇到过打checkpoint的时候,遇到写hdfs的错误然后一直卡死?状态非常大的时候,而且重启初始化非常的慢

Hadoop 分布式文件系统 HDFS

43 课时 |
945 人已学 |
免费
开发者课程背景图

问一下大佬们,我们最近flink任务从checkpoint(hdfs存储)恢复,发现恢复信息里还尝试

问一下大佬们,我们最近flink任务从checkpoint(hdfs存储)恢复,发现恢复信息里还尝试连接旧的hdfs(我们换了hdfs,把任务的checkpoint相关文件迁移到新的hdfs了),这样的问题遇到过么?或者checkpoint会存储集群的hdfs地址么?

问一下群里的大佬们,我们最近flink任务从checkpoint(hdfs存储)恢复,发现恢复信息里

问一下群里的大佬们,我们最近flink任务从checkpoint(hdfs存储)恢复,发现恢复信息里还尝试连接旧的hdfs(我们换了hdfs,把任务的checkpoint相关文件迁移到新的hdfs了),这样的问题遇到过么?或者checkpoint会存储集群的hdfs地址么?

请问一下,flink checkpoint 的hdfs 路径,有台机器磁盘坏了了,导致flink任务

请问一下,flink checkpoint 的hdfs 路径,有台机器磁盘坏了了,导致flink任务失败,这种问题集群感知到了,yarn有告警提示,后面我通知运维手动隔离了那台机器,请问有自动隔离的办法吗?这样的话任务应该不会失败了

从之前的checkpoint恢复运行,之后的checkpoint上传到hdfs的数据(300M)

从之前的checkpoint恢复运行,之后的checkpoint上传到hdfs的数据(300M)比之前checkpoint上传的数据量(1.5g)少,按理说我是全量checkpoint,不应该出现这种情况吧?

flink将checkpoint写入到hdfs中七天之后token过期,有大佬解决过这个问题吗?

flink将checkpoint写入到hdfs中七天之后token过期,有大佬解决过这个问题吗?

背景:配置Flink的高可用,想将checkpoint存放在hdfs上面,rpc 过长的错误。

测试机需要配置Flink的HA,需要将checkpoint存放在hdfs上,发现Flink集群无法启动,出现了rpc 过长的错误,但是发现Flink在未启动成功jobmanage和taskmanage后,将checkpoint存放在了HDFS上,我并没有hadoop的权限,测试集群也没有hadoop...

Flink怎么维护Checkpoint?在HDFS上存储的话会有小文件吗?

Flink怎么维护Checkpoint?在HDFS上存储的话会有小文件吗?

如何修改checkpoint生成的_metadata文件中的hdfs路径?

由于checkpoint生成的 _metadata中存的hdfs路径是绝对路径,我目前想要迁移到另外一个集群中,想修改这个_metadata文件的数据,请问如何进行修改,有哪些可以参考的?*来自志愿者整理的flink邮件归档

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

产品推荐

社区圈子

阿里云存储服务
阿里云存储服务
阿里云存储基于飞天盘古2.0分布式存储系统,产品多种多样,充分满足用户数据存储和迁移上云需求。
194040+人已加入
加入
相关电子书
更多
海量数据分布式存储——Apache HDFS之最新进展
立即下载