This is an automated email from the ASF dual-hosted git repository.
rskraba pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/avro.git
The following commit(s) were added to refs/heads/master by this push:
new 816893e AVRO2519 - prevent resource leak in NettyTransceiver (#961)
816893e is described below
commit 816893eb5cb7a71d9a06c3c5e27db2e2fb7bbb94
Author: Julian Wexler <[email protected]>
AuthorDate: Fri Oct 2 19:07:42 2020 +0200
AVRO2519 - prevent resource leak in NettyTransceiver (#961)
---
.../src/main/java/org/apache/avro/ipc/netty/NettyTransceiver.java | 2 ++
1 file changed, 2 insertions(+)
diff --git
a/lang/java/ipc-netty/src/main/java/org/apache/avro/ipc/netty/NettyTransceiver.java
b/lang/java/ipc-netty/src/main/java/org/apache/avro/ipc/netty/NettyTransceiver.java
index b6bcfe4..d75254a 100644
---
a/lang/java/ipc-netty/src/main/java/org/apache/avro/ipc/netty/NettyTransceiver.java
+++
b/lang/java/ipc-netty/src/main/java/org/apache/avro/ipc/netty/NettyTransceiver.java
@@ -199,6 +199,8 @@ public class NettyTransceiver extends Transceiver {
channelFuture.channel().close();
}
+ workerGroup.shutdownGracefully();
+
if (e instanceof IOException)
throw (IOException) e;
if (e instanceof RuntimeException)
