From 2ac5578730858af4763ca0906aebce8aba58c8f8 Mon Sep 17 00:00:00 2001
From: Duo Zhang <zhangduo@apache.org>
Date: Thu, 4 Aug 2022 23:14:04 +0800
Subject: [PATCH] HBASE-27271 Addendum use NettyFutureUtils

---
 .../java/org/apache/hadoop/hbase/ipc/NettyRpcConnection.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcConnection.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcConnection.java
index a0e2430125d..f761ec0b2dc 100644
--- a/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcConnection.java
+++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcConnection.java
@@ -239,7 +239,7 @@ class NettyRpcConnection extends RpcConnection {
             p.addBefore(BufferCallBeforeInitHandler.NAME, readTimeoutHandlerName,
               new ReadTimeoutHandler(RpcClient.DEFAULT_SOCKET_TIMEOUT_READ, TimeUnit.MILLISECONDS))
               .addBefore(BufferCallBeforeInitHandler.NAME, null, chHandler);
-            connectionHeaderPromise.addListener(new FutureListener<Boolean>() {
+            NettyFutureUtils.addListener(connectionHeaderPromise, new FutureListener<Boolean>() {
               @Override
               public void operationComplete(Future<Boolean> future) throws Exception {
                 if (future.isSuccess()) {