Flink 1.10 堆外内存一直在增加

2020-08-11 文章 ReignsDYL
各位好,
  Flink 1.10,集群在运行过程中,堆外内存一直在不断增加,内存就被慢慢耗尽,导致任务挂掉,请问是什么原因啊?



--
Sent from: http://apache-flink.147419.n8.nabble.com/

Re: checkpoint stage size的问题

2019-06-26 文章 ReignsDYL
这是web ui的监控
 



--
Sent from: http://apache-flink.147419.n8.nabble.com/


Re: checkpoint stage size的问题

2019-06-26 文章 ReignsDYL
我发现窗口的trigger只进行了fire,并没有进行purge,我不清楚是不是这个原因,或者还是有其他的原因。



--
Sent from: http://apache-flink.147419.n8.nabble.com/

checkpoint stage size的问题

2019-06-26 文章 ReignsDYL
各位好,我的项目的流计算模型source(kafka)->filter->keyby->window->aggregate->sink(hbase),现在发现window的subtask的checkpoint的stage
size越来越大,请问是什么原因啊?



--
Sent from: http://apache-flink.147419.n8.nabble.com/