diff --git a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/ipc/Server.java b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/ipc/Server.java index a9ec756154e..4b6b0fecca9 100644 --- a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/ipc/Server.java +++ b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/ipc/Server.java @@ -1777,7 +1777,7 @@ public abstract class Server { private SocketChannel channel; private ByteBuffer data; - private ByteBuffer dataLengthBuffer; + private final ByteBuffer dataLengthBuffer; private LinkedList responseQueue; // number of outstanding rpcs private AtomicInteger rpcCount = new AtomicInteger(); @@ -2744,7 +2744,6 @@ public abstract class Server { private synchronized void close() { disposeSasl(); data = null; - dataLengthBuffer = null; if (!channel.isOpen()) return; try {socket.shutdownOutput();} catch(Exception e) {