Skip to content

Commit 7edf24d

Browse files
committed
Fix code conflicts.
1 parent 70dcd81 commit 7edf24d

File tree

3 files changed

+16
-13
lines changed

3 files changed

+16
-13
lines changed

hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/datanode/TestBlockRecovery.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -705,7 +705,7 @@ public void testNotMatchedReplicaID() throws IOException {
705705
streams.close();
706706
}
707707
}
708-
708+
709709
/**
710710
* DNs report RUR instead of RBW, RWR or FINALIZED. Primary DN expected to
711711
* throw an exception.

hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/datanode/TestBlockRecovery2.java

Lines changed: 11 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -77,9 +77,9 @@
7777
import static org.apache.hadoop.hdfs.DFSConfigKeys.DFS_NAMENODE_HEARTBEAT_RECHECK_INTERVAL_KEY;
7878
import static org.apache.hadoop.hdfs.DFSConfigKeys.DFS_NAMENODE_REPLICATION_MIN_KEY;
7979
import static org.junit.Assert.assertEquals;
80-
import static org.mockito.ArgumentMatchers.any;
81-
import static org.mockito.ArgumentMatchers.anyLong;
82-
import static org.mockito.ArgumentMatchers.anyString;
80+
import static org.mockito.Matchers.any;
81+
import static org.mockito.Matchers.anyLong;
82+
import static org.mockito.Matchers.anyString;
8383
import static org.mockito.Mockito.doAnswer;
8484
import static org.mockito.Mockito.mock;
8585
import static org.mockito.Mockito.spy;
@@ -141,23 +141,23 @@ public void startUp() throws IOException {
141141
(Answer<DatanodeRegistration>) invocation ->
142142
(DatanodeRegistration) invocation.getArguments()[0])
143143
.when(namenode)
144-
.registerDatanode(Mockito.any(DatanodeRegistration.class));
144+
.registerDatanode(any(DatanodeRegistration.class));
145145

146146
when(namenode.versionRequest())
147147
.thenReturn(new NamespaceInfo(1, CLUSTER_ID, POOL_ID, 1L));
148148

149149
when(namenode.sendHeartbeat(
150-
Mockito.any(),
151-
Mockito.any(),
152-
Mockito.anyLong(),
153-
Mockito.anyLong(),
150+
any(),
151+
any(),
152+
anyLong(),
153+
anyLong(),
154154
Mockito.anyInt(),
155155
Mockito.anyInt(),
156156
Mockito.anyInt(),
157-
Mockito.any(),
157+
any(),
158158
Mockito.anyBoolean(),
159-
Mockito.any(),
160-
Mockito.any()))
159+
any(),
160+
any()))
161161
.thenReturn(new HeartbeatResponse(
162162
new DatanodeCommand[0],
163163
new NNHAStatusHeartbeat(HAServiceProtocol.HAServiceState.ACTIVE, 1),

hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/datanode/TestDataNodeReconfiguration.java

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -40,12 +40,15 @@
4040
import org.junit.Assert;
4141
import org.junit.Before;
4242
import org.junit.Test;
43+
import org.slf4j.Logger;
44+
import org.slf4j.LoggerFactory;
4345

4446
/**
4547
* Test to reconfigure some parameters for DataNode without restart
4648
*/
4749
public class TestDataNodeReconfiguration {
48-
50+
private static final Logger LOG =
51+
LoggerFactory.getLogger(TestBlockRecovery.class);
4952
private static final String DATA_DIR = MiniDFSCluster.getBaseDirectory()
5053
+ "data";
5154
private final static InetSocketAddress NN_ADDR = new InetSocketAddress(

0 commit comments

Comments
 (0)