managed memory????100%??????

[????????????]

??????????????????????????????????????1. 
????????????????????flink????????kafka????hdfs????????????????hdfs??????????????????????????hive????????????????????????????????????????????????????
 
??????????????????????????????????????kafka??????????hdfs??????????????????????managed
 
memory????????????????????????????100%??????????????????????hashmap+hdfs????????????????hive??sql????10??????????????+group
 by + sum??????????????????????????minibatch????????????????



2. ????????????????rocks 
db??????????????????????????????????????????????????????????????????????????0????????????????????????
java.lang.NullPointerException: Initial Segment may not be null
 at 
org.apache.flink.runtime.memory.AbstractPagedOutputView.<init&gt;(AbstractPagedOutputView.java:67)
&nbsp;at 
org.apache.flink.runtime.io.disk.SimpleCollectingOutputView.<init&gt;(SimpleCollectingOutputView.java:46)
&nbsp;at 
org.apache.flink.table.runtime.util.collections.binary.AbstractBytesMultiMap$RecordArea.<init&gt;(AbstractBytesMultiMap.java:226)
&nbsp;at 
org.apache.flink.table.runtime.util.collections.binary.AbstractBytesMultiMap.<init&gt;(AbstractBytesMultiMap.java:114)
&nbsp;at 
org.apache.flink.table.runtime.util.collections.binary.WindowBytesMultiMap.<init&gt;(WindowBytesMultiMap.java:40)
&nbsp;at 
org.apache.flink.table.runtime.operators.aggregate.window.buffers.RecordsWindowBuffer.<init&gt;(RecordsWindowBuffer.java:72)
&nbsp;at 
org.apache.flink.table.runtime.operators.aggregate.window.buffers.RecordsWindowBuffer$Factory.create(RecordsWindowBuffer.java:164)
&nbsp;at 
org.apache.flink.table.runtime.operators.aggregate.window.processors.AbstractWindowAggProcessor.open(AbstractWindowAggProcessor.java:118)
&nbsp;at 
org.apache.flink.table.runtime.operators.window.slicing.SlicingWindowOperator.open(SlicingWindowOperator.java:152)
&nbsp;at 
org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.initializeStateAndOpenOperators(RegularOperatorChain.java:107)
&nbsp;at 
org.apache.flink.streaming.runtime.tasks.StreamTask.restoreGates(StreamTask.java:726)
&nbsp;at 
org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.call(StreamTaskActionExecutor.java:55)
&nbsp;at 
org.apache.flink.streaming.runtime.tasks.StreamTask.restoreInternal(StreamTask.java:702)
&nbsp;at 
org.apache.flink.streaming.runtime.tasks.StreamTask.restore(StreamTask.java:669)
&nbsp;at 
org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:935)
&nbsp;at 
org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:904)
&nbsp;at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:728)
&nbsp;at org.apache.flink.runtime.taskmanager.Task.run(Task.java:550)
&nbsp;at java.lang.Thread.run(Thread.java:748)



3. ??????????????????????



4. 
????managed??????????????????????????????????????????????????kafka????????????????????managed??????????????????????????????????????