开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

Flink CDC中使用rocksdb 状态后端一直提示要调整task 内存大小,这个一般调整到?

Flink CDC中使用rocksdb 状态后端一直提示要调整task 内存大小,这个一般调整到多大啊大佬?image.png

展开
收起
真的很搞笑 2023-08-01 14:59:34 96 0
1 条回答
写回答
取消 提交回答
  • 北京阿里云ACE会长

    在Flink CDC中使用RocksDB状态后端时,RocksDB使用的内存大小会影响TaskManager的内存使用情况。如果RocksDB使用的内存超过了TaskManager所配置的内存大小,则会导致OOM(Out Of Memory)错误。 因此,为了避免这种情况,需要根据具体情况调整TaskManager的内存大小。

    通常情况下,可以通过以下步骤来确定TaskManager的适当内存大小:

    首先,需要确定每个TaskManager所分配的最大内存大小,即 taskmanager.memory.process.size。这个值通常设置为 TaskManager 所在机器的物理内存大小的70%~80%。

    接下来,需要考虑RocksDB使用的内存大小。可以通过以下参数来控制RocksDB使用的内存大小。

    state.backend.rocksdb.memory.managed:设置RocksDB使用的受管理内存大小。这个值通常设置为 TaskManager 所分配的最大内存大小的50%~60%。

    state.backend.rocksdb.memory.write.buffer.ratio:设置RocksDB用于写入缓冲区的内存比率。这个值通常设置为0.4~0.5。

    state.backend.rocksdb.memory.high.priority.pool.ratio:设置RocksDB用于高优先级内存池的内存比率。这个值通常设置为0.1~0.2。

    最后,需要根据以上参数计算出RocksDB使用的总内存大小,然后将其与TaskManager所分配的最大内存大小进行比较,以确保RocksDB使用的内存大小不会超过TaskManager所分配的最大内存大小。

    根据以上步骤,可以大致估计出TaskManager的适当内存大小。但是,实际上,TaskManager的内存大小还会受到其他因素的影响,如JVM的堆内存大小、网络缓冲区的大小等。因此,需要根据具体情况来进行调整。

    2023-08-01 19:18:48
    赞同 展开评论 打赏

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

相关产品

  • 实时计算 Flink版
  • 相关电子书

    更多
    Flink CDC Meetup PPT - 龚中强 立即下载
    Flink CDC Meetup PPT - 王赫 立即下载
    Flink CDC Meetup PPT - 覃立辉 立即下载