Skip to content

Commit f34203b

Browse files
author
Ritesh Garg
committed
Fixing checkstyle issues
1 parent eab85c6 commit f34203b

File tree

2 files changed

+9
-8
lines changed

2 files changed

+9
-8
lines changed

hadoop-hdfs-project/hadoop-hdfs-client/src/main/java/org/apache/hadoop/hdfs/DataStreamer.java

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -648,13 +648,13 @@ protected void setPipeline(LocatedBlock lb) {
648648
setPipeline(lb.getLocations(), lb.getStorageTypes(), lb.getStorageIDs());
649649
}
650650

651-
protected void setPipeline(DatanodeInfo[] nodes, StorageType[] storageTypes,
652-
String[] storageIDs) {
651+
protected void setPipeline(DatanodeInfo[] newNodes, StorageType[] newStorageTypes,
652+
String[] newStorageIDs) {
653653
synchronized (nodesLock) {
654-
this.nodes = nodes;
654+
this.nodes = newNodes;
655655
}
656-
this.storageTypes = storageTypes;
657-
this.storageIDs = storageIDs;
656+
this.storageTypes = newStorageTypes;
657+
this.storageIDs = newStorageIDs;
658658
}
659659

660660
/**

hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/TestDistributedFileSystem.java

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -2680,7 +2680,7 @@ public void testSingleRackFailureDuringPipelineSetupMinReplicationPossible() thr
26802680

26812681
@Test
26822682
public void testSingleRackFailureDuringPipelineSetupMinReplicationImpossible()
2683-
throws Exception {
2683+
throws Exception {
26842684
Configuration conf = getTestConfiguration();
26852685
conf.setClass(DFSConfigKeys.DFS_BLOCK_REPLICATOR_CLASSNAME_KEY,
26862686
BlockPlacementPolicyRackFaultTolerant.class, BlockPlacementPolicy.class);
@@ -2730,7 +2730,8 @@ public void testMultipleRackFailureDuringPipelineSetupMinReplicationPossible() t
27302730
public void testMultipleRackFailureDuringPipelineSetupMinReplicationImpossible()
27312731
throws Exception {
27322732
Configuration conf = getTestConfiguration();
2733-
conf.setClass(DFSConfigKeys.DFS_BLOCK_REPLICATOR_CLASSNAME_KEY, BlockPlacementPolicyRackFaultTolerant.class,
2733+
conf.setClass(DFSConfigKeys.DFS_BLOCK_REPLICATOR_CLASSNAME_KEY,
2734+
BlockPlacementPolicyRackFaultTolerant.class,
27342735
BlockPlacementPolicy.class);
27352736
conf.setBoolean(
27362737
HdfsClientConfigKeys.BlockWrite.ReplaceDatanodeOnFailure.ENABLE_KEY,
@@ -2772,7 +2773,7 @@ public void testAllRackFailureDuringPipelineSetup() throws Exception {
27722773
// create a file with replication 3, for rack fault tolerant BPP,
27732774
// it should allocate nodes in all 3 rack but fail because no DNs are present.
27742775
LambdaTestUtils.intercept(IOException.class,
2775-
() ->
2776+
() ->
27762777
DFSTestUtil.createFile(fs, new Path("/testFile"),
27772778
1024L, (short) 3, 1024L));
27782779
}

0 commit comments

Comments
 (0)