[avro] branch branch-1.10 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 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 <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)