[ https://issues.apache.org/jira/browse/BEAM-5397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16617416#comment-16617416 ]
Thomas Weise commented on BEAM-5397: ------------------------------------ {code:java} Exception in thread "grpc-default-worker-ELG-3-2" java.lang.NoClassDefFoundError: org/apache/beam/vendor/netty/v4/io/netty/buffer/PoolArena$1 at org.apache.beam.vendor.netty.v4.io.netty.buffer.PoolArena.freeChunk(PoolArena.java:293) at org.apache.beam.vendor.netty.v4.io.netty.buffer.PoolThreadCache$MemoryRegionCache.freeEntry(PoolThreadCache.java:443) at org.apache.beam.vendor.netty.v4.io.netty.buffer.PoolThreadCache$MemoryRegionCache.free(PoolThreadCache.java:413) at org.apache.beam.vendor.netty.v4.io.netty.buffer.PoolThreadCache$MemoryRegionCache.free(PoolThreadCache.java:405) at org.apache.beam.vendor.netty.v4.io.netty.buffer.PoolThreadCache.free(PoolThreadCache.java:262) at org.apache.beam.vendor.netty.v4.io.netty.buffer.PoolThreadCache.free(PoolThreadCache.java:253) at org.apache.beam.vendor.netty.v4.io.netty.buffer.PoolThreadCache.free(PoolThreadCache.java:226) at org.apache.beam.vendor.netty.v4.io.netty.buffer.PooledByteBufAllocator$PoolThreadLocalCache.onRemoval(PooledByteBufAllocator.java:450) at org.apache.beam.vendor.netty.v4.io.netty.buffer.PooledByteBufAllocator$PoolThreadLocalCache.onRemoval(PooledByteBufAllocator.java:426) at org.apache.beam.vendor.netty.v4.io.netty.util.concurrent.FastThreadLocal.remove(FastThreadLocal.java:269) at org.apache.beam.vendor.netty.v4.io.netty.util.concurrent.FastThreadLocal.removeAll(FastThreadLocal.java:68) at org.apache.beam.vendor.netty.v4.io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:32) at java.lang.Thread.run(Thread.java:748) Caused by: java.lang.ClassNotFoundException: org.apache.beam.vendor.netty.v4.io.netty.buffer.PoolArena$1 at java.net.URLClassLoader.findClass(URLClassLoader.java:381) at java.lang.ClassLoader.loadClass(ClassLoader.java:424) at org.apache.flink.runtime.execution.librarycache.FlinkUserCodeClassLoaders$ChildFirstClassLoader.loadClass(FlinkUserCodeClassLoaders.java:129) at java.lang.ClassLoader.loadClass(ClassLoader.java:357) ... 13 more{code} > Flink portable runner GRPC cleanup failure after user class loader was removed > ------------------------------------------------------------------------------ > > Key: BEAM-5397 > URL: https://issues.apache.org/jira/browse/BEAM-5397 > Project: Beam > Issue Type: Improvement > Components: runner-flink > Affects Versions: 2.8.0 > Reporter: Thomas Weise > Priority: Major > Labels: portability > > Looks like another attempt to perform cleanup after close. -- This message was sent by Atlassian JIRA (v7.6.3#76005)