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 xy...@apache.org on 2019/04/17 17:38:55 UTC
[hadoop] branch trunk updated: HDFS-14433. Remove the extra empty
space in the DataStreamer logging. Contributed by Yishuang Lu. (#747)
This is an automated email from the ASF dual-hosted git repository.
xyao pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/hadoop.git
The following commit(s) were added to refs/heads/trunk by this push:
new 685cb83 HDFS-14433. Remove the extra empty space in the DataStreamer logging. Contributed by Yishuang Lu. (#747)
685cb83 is described below
commit 685cb83e4c3f433c5147e35217ce79ea520a0da5
Author: lys0716 <lu...@gmail.com>
AuthorDate: Wed Apr 17 10:38:48 2019 -0700
HDFS-14433. Remove the extra empty space in the DataStreamer logging. Contributed by Yishuang Lu. (#747)
---
.../src/main/java/org/apache/hadoop/hdfs/DataStreamer.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/hadoop-hdfs-project/hadoop-hdfs-client/src/main/java/org/apache/hadoop/hdfs/DataStreamer.java b/hadoop-hdfs-project/hadoop-hdfs-client/src/main/java/org/apache/hadoop/hdfs/DataStreamer.java
index 0029a76..54425b1 100644
--- a/hadoop-hdfs-project/hadoop-hdfs-client/src/main/java/org/apache/hadoop/hdfs/DataStreamer.java
+++ b/hadoop-hdfs-project/hadoop-hdfs-client/src/main/java/org/apache/hadoop/hdfs/DataStreamer.java
@@ -1152,7 +1152,7 @@ class DataStreamer extends Daemon {
one = ackQueue.getFirst();
}
if (one.getSeqno() != seqno) {
- throw new IOException("ResponseProcessor: Expecting seqno " +
+ throw new IOException("ResponseProcessor: Expecting seqno" +
" for block " + block +
one.getSeqno() + " but received " + seqno);
}
@@ -1386,7 +1386,7 @@ class DataStreamer extends Daemon {
if (dfsClient.dtpReplaceDatanodeOnFailureReplication > 0 && nodes.length
>= dfsClient.dtpReplaceDatanodeOnFailureReplication) {
DFSClient.LOG.warn(
- "Failed to find a new datanode to add to the write pipeline, "
+ "Failed to find a new datanode to add to the write pipeline,"
+ " continue to write to the pipeline with " + nodes.length
+ " nodes since it's no less than minimum replication: "
+ dfsClient.dtpReplaceDatanodeOnFailureReplication
---------------------------------------------------------------------
To unsubscribe, e-mail: common-commits-unsubscribe@hadoop.apache.org
For additional commands, e-mail: common-commits-help@hadoop.apache.org