big-data/hadoop
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

HDFS-14451. Incorrect header or version mismatch log message. Contributed by Shweta.

Browse Source 
Signed-off-by: Wei-Chiu Chuang <weichiu@apache.org>
This commit is contained in:
Shweta 2019-05-24 18:41:45 +02:00 committed by Wei-Chiu Chuang
parent 460ba7fb14
commit 93d7630062
1 changed files with 10 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -2233,11 +2233,17 @@ public int readAndProcess() throws IOException, InterruptedException {
setupHttpRequestOnIpcPortResponse(); setupHttpRequestOnIpcPortResponse();
return -1; return -1;
} }
if (!RpcConstants.HEADER.equals(dataLengthBuffer) if(!RpcConstants.HEADER.equals(dataLengthBuffer)) {
|| version != CURRENT_VERSION) { LOG.warn("Incorrect RPC Header length from {}:{} "
+ "expected length: {} got length: {}",
hostAddress, remotePort, RpcConstants.HEADER, dataLengthBuffer);
setupBadVersionResponse(version);
return -1;
}
if (version != CURRENT_VERSION) {
//Warning is ok since this is not supposed to happen. //Warning is ok since this is not supposed to happen.
LOG.warn("Incorrect header or version mismatch from " + LOG.warn("Version mismatch from " +
hostAddress + ":" + remotePort + hostAddress + ":" + remotePort +
" got version " + version + " got version " + version +
" expected version " + CURRENT_VERSION); " expected version " + CURRENT_VERSION);