diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/io/asyncfs/FanOutOneBlockAsyncDFSOutputSaslHelper.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/io/asyncfs/FanOutOneBlockAsyncDFSOutputSaslHelper.java index c4c9bc53ae..e389bc3a50 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/io/asyncfs/FanOutOneBlockAsyncDFSOutputSaslHelper.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/io/asyncfs/FanOutOneBlockAsyncDFSOutputSaslHelper.java @@ -465,6 +465,7 @@ public final class FanOutOneBlockAsyncDFSOutputSaslHelper { @Override public void channelInactive(ChannelHandlerContext ctx) throws Exception { saslClient.dispose(); + promise.tryFailure(new IOException("connection is closed by dataNode")); } private void check(DataTransferEncryptorMessageProto proto) throws IOException {