From 685cb83e4c3f433c5147e35217ce79ea520a0da5 Mon Sep 17 00:00:00 2001 From: lys0716 Date: Wed, 17 Apr 2019 10:38:48 -0700 Subject: [PATCH] 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 0029a7643c..54425b1c6d 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 @@ public void run() { 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 @@ private void addDatanode2ExistingPipeline() throws IOException { 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