hadoop-common-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From aengin...@apache.org
Subject [10/50] hadoop git commit: HDFS-10381, DataStreamer DataNode exclusion log message should be warning. (John Zhuge via Yongjun Zhang)
Date Mon, 23 May 2016 23:20:48 GMT
HDFS-10381, DataStreamer DataNode exclusion log message should be warning. (John Zhuge via
Yongjun Zhang)


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

Branch: refs/heads/HDFS-1312
Commit: 16c07cc68a3e0a06f57b7f4c7207cc8e5dce211f
Parents: 03788d3
Author: Yongjun Zhang <yzhang@cloudera.com>
Authored: Tue May 17 15:45:15 2016 -0700
Committer: Yongjun Zhang <yzhang@cloudera.com>
Committed: Tue May 17 15:57:33 2016 -0700

----------------------------------------------------------------------
 .../src/main/java/org/apache/hadoop/hdfs/DataStreamer.java       | 4 ++--
 .../main/java/org/apache/hadoop/hdfs/StripedDataStreamer.java    | 2 +-
 2 files changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hadoop/blob/16c07cc6/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 1b7306a..ee673ed 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
@@ -1518,12 +1518,12 @@ class DataStreamer extends Daemon {
       success = createBlockOutputStream(nodes, storageTypes, 0L, false);
 
       if (!success) {
-        LOG.info("Abandoning " + block);
+        LOG.warn("Abandoning " + block);
         dfsClient.namenode.abandonBlock(block, stat.getFileId(), src,
             dfsClient.clientName);
         block = null;
         final DatanodeInfo badNode = nodes[errorState.getBadNodeIndex()];
-        LOG.info("Excluding datanode " + badNode);
+        LOG.warn("Excluding datanode " + badNode);
         excludedNodes.put(badNode, badNode);
       }
     } while (!success && --count >= 0);

http://git-wip-us.apache.org/repos/asf/hadoop/blob/16c07cc6/hadoop-hdfs-project/hadoop-hdfs-client/src/main/java/org/apache/hadoop/hdfs/StripedDataStreamer.java
----------------------------------------------------------------------
diff --git a/hadoop-hdfs-project/hadoop-hdfs-client/src/main/java/org/apache/hadoop/hdfs/StripedDataStreamer.java
b/hadoop-hdfs-project/hadoop-hdfs-client/src/main/java/org/apache/hadoop/hdfs/StripedDataStreamer.java
index 8f4efcc..89ab6a3 100644
--- a/hadoop-hdfs-project/hadoop-hdfs-client/src/main/java/org/apache/hadoop/hdfs/StripedDataStreamer.java
+++ b/hadoop-hdfs-project/hadoop-hdfs-client/src/main/java/org/apache/hadoop/hdfs/StripedDataStreamer.java
@@ -107,7 +107,7 @@ public class StripedDataStreamer extends DataStreamer {
     if (!success) {
       block = null;
       final DatanodeInfo badNode = nodes[getErrorState().getBadNodeIndex()];
-      LOG.info("Excluding datanode " + badNode);
+      LOG.warn("Excluding datanode " + badNode);
       excludedNodes.put(badNode, badNode);
       throw new IOException("Unable to create new block." + this);
     }


---------------------------------------------------------------------
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