问答 2022-08-31 来自:开发者社区

在 Flink 中,很多地方都涉及到本地磁盘的读写,比如日志输出、RocksDB 读写、批 任务 s

在 Flink 中,很多地方都涉及到本地磁盘的读写,比如日志输出、RocksDB 读写、批任务 shuffle 等。那么该如何处理来减小影响?

问答 2022-08-12 来自:开发者社区

请问有大佬遇到过Docker部署Flink,TaskManager中检查点文件一直增长导致磁盘爆满的

请问有大佬遇到过Docker部署Flink,TaskManager中检查点文件一直增长导致磁盘爆满的问题吗?好奇为啥TaskManager上也有检查点文件,另外为啥配置了保留十个检查点没生效。

问答 2022-08-05 来自:开发者社区

打扰下,请教个问题,checkpoint 使用file://存储在本地磁盘时,flink集群中tas

打扰下,请教个问题,checkpoint 使用file://存储在本地磁盘时,flink集群中taskmanager和jobmanager所在的节点都会储存checkpoint 信息,这个是jobmanager保存的是一份完整的,taskmanager存自己的一部分嘛,没找到相关资料,有大佬做过本地存储的嘛

问答 2022-07-20 来自:开发者社区

请问flink写hudi,数据一直没有写磁盘是什么原因啊?是在建表的时候要设置参数:write.ba

请问flink写hudi,数据一直没有写磁盘是什么原因啊?是在建表的时候要设置参数:write.batch.size?这个参数默认是什么单位?B、KB、MB?

问答 2021-12-08 来自:开发者社区

Flink大state读取磁盘,磁盘IO打满,任务相互影响的问题探讨

如题,Flink大state读取磁盘,磁盘IO打满,任务相互影响的问题 尝试手段: 手动迁移IO比较高的任务到其他机器,但是yarn任务提交比较随机,只能偶尔为之 目前没有SSD,只能用普通STATA盘,目前加了两块盘提示磁盘IO能力,但是单盘对单任务的磁盘IO瓶颈还在 还有哪些策略可以解决或者缓解么?*来自志愿者整理的flink邮件归档

问答 2019-12-02 来自:开发者社区

大佬们flink检查点存hdfs的话怎么自动清理文件啊 一个128M很快磁盘就满了

大佬们flink检查点存hdfs的话怎么自动清理文件啊 一个128M很快磁盘就满了 问题来自阿里云开发者社区的【11大垂直技术领域开发者社群】。 点击这里欢迎加入感兴趣的技术领域群。

问答 2018-11-23 来自:开发者社区

各位大佬,flink state mapstate 保存数据100g 采用rocksdb增量更新 job 任务运行一段时间就死了。磁盘采用非ssd 。对于large state value 任务 有什么好的建议。

各位大佬,flink state mapstate 保存数据100g 采用rocksdb增量更新 job 任务运行一段时间就死了。磁盘采用非ssd 。对于large state value 任务 有什么好的建议。

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

产品推荐

阿里云实时计算Flink

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

+关注