spark任務在集群跑一段時間大概在10h左右后報錯掉線。ERROR util.ResourceLeakDetector: LEAK: ByteBuf.release()

 

ERROR util.ResourceLeakDetector: LEAK: ByteBuf.release() was not called before it's garbage-collected. Enable advanced leak reporting to find out where the leak occurred. To enable advanced leak reporting, specify the JVM option '-Dio.netty.leakDetection.level=advanced' or call ResourceLeakDetector.setLevel() See http://netty.io/wiki/reference-counted-objects.html for more information.
使用下面的方法手動釋放直接緩沖區：
ReferenceCountUtil.releaseLater(Unpooled.directBuffer(512));