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

请问下总共60多个flink表,30多个源,30多个目标,30多个转换,数据量不多这种需要的内存大概

请问下总共60多个flink表,30多个源,30多个目标,30多个转换,数据量不多这种需要的内存大概需要多大和cpu配置这些,感觉是资源没被释放,最开始运行时就占用6,7个g,持续跑了20分钟现在基本也占满了image.png 没用springboot了,是javamaven项目准备加载进flink任务image.png

展开
收起
真的很搞笑 2023-05-09 13:34:17 128 0
1 条回答
写回答
取消 提交回答
  • 存在即是合理

    在处理60多个Flink表、30多个源、30多个目标和30多个转换的情况下,需要考虑的内存和CPU配置因系统环境而异。但是,由于数据量不大,可能不需要太高的内存和CPU资源。

    以下是一些可能有用的建议:

    1. 调整JVM参数:可以通过调整JVM参数来优化内存使用情况。例如,可以使用-Xmx和-Xms参数来设置JVM的最大和最小堆大小。此外,还可以使用-XX:+UseParallelGC和-XX:+UseConcMarkSweepGC等参数来调整垃圾收集器的行为。

    2. 调整并行度:可以将并行度设置为适当的值,以平衡内存和性能的需求。如果并行度过高,可能会导致内存不足;如果并行度过低,可能会导致性能不佳。

    3. 使用分区:可以使用分区将数据分散到不同的任务中,从而减少单个任务的内存和CPU负载。

    4. 清理状态:定期清理Flink作业的状态可以释放内存。可以使用Flink的cleanupJob()方法或手动删除状态目录来清理状态。

    5. 监控资源使用情况:可以使用Flink的监控工具来监控内存和CPU使用情况,以及作业的运行状况。这可以帮助您及时发现和解决资源占用过高的问题。

    需要注意的是,以上建议仅供参考,具体的内存和CPU配置需要根据实际情况进行调整。

    2023-05-11 19:42:37
    赞同 展开评论 打赏

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

相关产品

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

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