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

HDFS-13730. BlockReaderRemote.sendReadResult throws NPE. Contributed by Yuanbo Liu. 

(cherry picked from commit 62ad9885ea)
(cherry picked from commit 45543ffd6a)
(cherry picked from commit fc8983a5b8)
(cherry picked from commit 79f8e4d5bc)
This commit is contained in:
Wei-Chiu Chuang 2019-06-17 20:18:53 -07:00
parent 73a59b2c42
commit ce49f8a5df
2 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
hadoop-hdfs-project/hadoop-hdfs-client/src/main/java/org/apache/hadoop/hdfs/net/BasicInetPeer.java
View File

@ -21,6 +21,7 @@ import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;
import java.net.SocketAddress;
import java.nio.channels.ReadableByteChannel;
import org.apache.hadoop.net.unix.DomainSocket;
@ -93,7 +94,8 @@ public class BasicInetPeer implements Peer {
@Override
public String getRemoteAddressString() {
return socket.getRemoteSocketAddress().toString();
SocketAddress address = socket.getRemoteSocketAddress();
return address == null ? null : address.toString();
}
@Override

4
hadoop-hdfs-project/hadoop-hdfs-client/src/main/java/org/apache/hadoop/hdfs/net/NioInetPeer.java
View File

@ -21,6 +21,7 @@ import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;
import java.net.SocketAddress;
import java.nio.channels.ReadableByteChannel;
import org.apache.hadoop.net.SocketInputStream;
@ -96,7 +97,8 @@ public class NioInetPeer implements Peer {
@Override
public String getRemoteAddressString() {
return socket.getRemoteSocketAddress().toString();
SocketAddress address = socket.getRemoteSocketAddress();
return address == null ? null : address.toString();
}
@Override