HDFS-10822. Log DataNodes in the write pipeline. John Zhuge via Lei Xu
(cherry picked from commit 5a8c5064d1a1d596b1f5c385299a86ec6ab9ad1e)
This commit is contained in:
parent
28ea4122f0
commit
d6bfb2176c
@ -484,6 +484,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;
|
||||
|
Loading…
x
Reference in New Issue
Block a user