[avro] branch master updated: AVRO2519 - prevent resource leak in NettyTransceiver (#961)

[rs...@apache.org]

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 <41...@users.noreply.github.com>
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)