Flink 测试运行,遇到的GC跟taskmanager挂掉问题

1,出现这个,因为代码写的是Json类型,算子与算子之间下发json对象,没有序列化,都改成pojo 实现序列化,可以减轻内存消耗   2,因为有个业务是全量统计,会存储历史状态,所以内存要设置大一点,设置 RocksDBStateBackend存储,设置TTL,之前可能压力测试3个小时TM就死了,再次测试 超过十几个小时任务都还比较稳定 3,安装JVM工具监控JVM的情况,并且在conf文件配
相关文章
相关标签/搜索