Hi

我的作业是运行在1.10.1, 使用的是event time ,没有开启checkPoint。每当作业重启一次,container memory 
usage会上涨2G,每重启一次就会上涨一些内存直到被OS kill。


历史数据的清理是在新event time到达之后调用 WindowOperator#onEventTime() 
的clearAllState实现清理,如果作业重启,又没有开启checkpoint,尚未被处理的历史数据是否一直残留在内存中无法清理?


是否有哪位大佬可以帮忙解惑?

| |
a511955993
|
|
邮箱:[email protected]
|

签名由 网易邮箱大师 定制

回复