You are viewing a plain text version of this content. The canonical link for it is here.
Posted to common-commits@hadoop.apache.org by we...@apache.org on 2019/05/24 16:44:14 UTC
[hadoop] branch branch-3.1 updated: HDFS-14451. Incorrect header or
version mismatch log message. Contributed by Shweta.
This is an automated email from the ASF dual-hosted git repository.
weichiu pushed a commit to branch branch-3.1
in repository https://gitbox.apache.org/repos/asf/hadoop.git
The following commit(s) were added to refs/heads/branch-3.1 by this push:
new a6ff20d HDFS-14451. Incorrect header or version mismatch log message. Contributed by Shweta.
a6ff20d is described below
commit a6ff20d25da2af9d0081b0b6f60045c6e71aa571
Author: Shweta <sh...@cloudera.com>
AuthorDate: Fri May 24 18:41:45 2019 +0200
HDFS-14451. Incorrect header or version mismatch log message. Contributed by Shweta.
Signed-off-by: Wei-Chiu Chuang <we...@apache.org>
(cherry picked from commit 93d7630062247793a4860704fad4a31437693de1)
(cherry picked from commit 7a5d9ab9eed194fabe609def69efe41bea4ed1f6)
---
.../src/main/java/org/apache/hadoop/ipc/Server.java | 14 ++++++++++----
1 file changed, 10 insertions(+), 4 deletions(-)
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 041b2b4..196b3d1 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
@@ -2066,11 +2066,17 @@ public abstract class Server {
setupHttpRequestOnIpcPortResponse();
return -1;
}
-
- if (!RpcConstants.HEADER.equals(dataLengthBuffer)
- || version != CURRENT_VERSION) {
+
+ if(!RpcConstants.HEADER.equals(dataLengthBuffer)) {
+ 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.
- LOG.warn("Incorrect header or version mismatch from " +
+ LOG.warn("Version mismatch from " +
hostAddress + ":" + remotePort +
" got version " + version +
" expected version " + CURRENT_VERSION);
---------------------------------------------------------------------
To unsubscribe, e-mail: common-commits-unsubscribe@hadoop.apache.org
For additional commands, e-mail: common-commits-help@hadoop.apache.org