hadoop-common-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From l..@apache.org
Subject hadoop git commit: HDFS-10822. Log DataNodes in the write pipeline. John Zhuge via Lei Xu
Date Fri, 02 Sep 2016 18:02:47 GMT
Repository: hadoop
Updated Branches:
  refs/heads/branch-2 28ea4122f -> d6bfb2176


HDFS-10822. Log DataNodes in the write pipeline. John Zhuge via Lei Xu

(cherry picked from commit 5a8c5064d1a1d596b1f5c385299a86ec6ab9ad1e)


Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo
Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/d6bfb217
Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/d6bfb217
Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/d6bfb217

Branch: refs/heads/branch-2
Commit: d6bfb2176cf9e3efc5e4bf1afa694266e3c6f394
Parents: 28ea412
Author: Lei Xu <lei@apache.org>
Authored: Fri Sep 2 11:01:13 2016 -0700
Committer: Lei Xu <lei@apache.org>
Committed: Fri Sep 2 11:02:38 2016 -0700

----------------------------------------------------------------------
 .../src/main/java/org/apache/hadoop/hdfs/DataStreamer.java     | 6 ++++++
 1 file changed, 6 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hadoop/blob/d6bfb217/hadoop-hdfs-project/hadoop-hdfs-client/src/main/java/org/apache/hadoop/hdfs/DataStreamer.java
----------------------------------------------------------------------
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 bdd20c4..67581e9 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
@@ -484,6 +484,12 @@ class DataStreamer extends Daemon {
   private void initDataStreaming() {
     this.setName("DataStreamer for file " + src +
         " block " + block);
+    if (LOG.isDebugEnabled()) {
+      LOG.debug("nodes {} storageTypes {} storageIDs {}",
+          Arrays.toString(nodes),
+          Arrays.toString(storageTypes),
+          Arrays.toString(storageIDs));
+    }
     response = new ResponseProcessor(nodes);
     response.start();
     stage = BlockConstructionStage.DATA_STREAMING;


---------------------------------------------------------------------
To unsubscribe, e-mail: common-commits-unsubscribe@hadoop.apache.org
For additional commands, e-mail: common-commits-help@hadoop.apache.org


Mime
View raw message