This is an automated email from the ASF dual-hosted git repository.
rskraba pushed a commit to branch branch-1.10
in repository https://gitbox.apache.org/repos/asf/avro.git
The following commit(s) were added to refs/heads/branch-1.10 by this push:
new 927b6ef AVRO2519 - prevent resource leak in NettyTransceiver (#961)
927b6ef is described below
commit 927b6efcecc0521ff5d47d802e37dc5233f5ebae
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)
