Apache
/
hadoop
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HADOOP-16868. ipc.Server readAndProcess threw NullPointerException. Contributed by Tsz-wo Sze. 

(cherry picked from commit cb3f3cca01)
(cherry picked from commit d411a849e1)
This commit is contained in:
Wei-Chiu Chuang 2020-02-18 21:53:08 -08:00
parent a6124cd2b8
commit b28347d282
1 changed files with 1 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/ipc/Server.java
View File

@ -1789,7 +1789,7 @@ public abstract class Server {
private SocketChannel channel; private SocketChannel channel;
private ByteBuffer data; private ByteBuffer data;
private ByteBuffer dataLengthBuffer; private final ByteBuffer dataLengthBuffer;
private LinkedList<RpcCall> responseQueue; private LinkedList<RpcCall> responseQueue;
// number of outstanding rpcs // number of outstanding rpcs
private AtomicInteger rpcCount = new AtomicInteger(); private AtomicInteger rpcCount = new AtomicInteger();
@ -2833,7 +2833,6 @@ public abstract class Server {
private synchronized void close() { private synchronized void close() {
disposeSasl(); disposeSasl();
data = null; data = null;
dataLengthBuffer = null;
if (!channel.isOpen()) if (!channel.isOpen())
return; return;
try {socket.shutdownOutput();} catch(Exception e) { try {socket.shutdownOutput();} catch(Exception e) {