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 062a416095..5166c8c79c 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 @@ -508,6 +508,12 @@ private void setPipeline(DatanodeInfo[] nodes, StorageType[] storageTypes, 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;