Skip to content

Commit 6a94ef7

Browse files
committedMar 6, 2025·
Fixed tests
1 parent 39340a6 commit 6a94ef7

File tree

2 files changed

+13
-4
lines changed

2 files changed

+13
-4
lines changed
 

‎hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/ozone/TestDataUtil.java

+5-1
Original file line numberDiff line numberDiff line change
@@ -32,6 +32,8 @@
3232
import java.util.Scanner;
3333
import org.apache.commons.lang3.RandomStringUtils;
3434
import org.apache.hadoop.hdds.client.ReplicationConfig;
35+
import org.apache.hadoop.hdds.client.ReplicationFactor;
36+
import org.apache.hadoop.hdds.client.ReplicationType;
3537
import org.apache.hadoop.hdds.protocol.StorageType;
3638
import org.apache.hadoop.hdds.utils.db.Table;
3739
import org.apache.hadoop.hdds.utils.db.TableIterator;
@@ -217,7 +219,9 @@ public static Map<String, OmKeyInfo> createKeys(MiniOzoneCluster cluster, int nu
217219
OzoneBucket bucket = createVolumeAndBucket(client);
218220
for (int i = 0; i < numOfKeys; i++) {
219221
String keyName = RandomStringUtils.randomAlphabetic(5) + i;
220-
createKey(bucket, keyName, RandomStringUtils.randomAlphabetic(5).getBytes(UTF_8));
222+
createKey(bucket, keyName,ReplicationConfig
223+
.fromTypeAndFactor(ReplicationType.RATIS, ReplicationFactor.ONE),
224+
RandomStringUtils.randomAlphabetic(5).getBytes(UTF_8));
221225
keyLocationMap.put(keyName, lookupOmKeyInfo(cluster, bucket, keyName));
222226
}
223227
}

‎hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/ozone/om/TestOMDbCheckpointServlet.java

+8-3
Original file line numberDiff line numberDiff line change
@@ -98,6 +98,9 @@
9898
import javax.servlet.http.HttpServletRequest;
9999
import javax.servlet.http.HttpServletResponse;
100100
import org.apache.hadoop.fs.FileUtil;
101+
import org.apache.hadoop.hdds.client.ReplicationConfig;
102+
import org.apache.hadoop.hdds.client.ReplicationFactor;
103+
import org.apache.hadoop.hdds.client.ReplicationType;
101104
import org.apache.hadoop.hdds.conf.OzoneConfiguration;
102105
import org.apache.hadoop.hdds.utils.IOUtils;
103106
import org.apache.hadoop.hdds.utils.db.DBCheckpoint;
@@ -676,9 +679,11 @@ private void prepSnapshotData() throws Exception {
676679
.createVolumeAndBucket(client);
677680

678681
// Create dummy keys for snapshotting.
679-
TestDataUtil.createKey(bucket, UUID.randomUUID().toString(),
680-
"content".getBytes(StandardCharsets.UTF_8));
681-
TestDataUtil.createKey(bucket, UUID.randomUUID().toString(),
682+
TestDataUtil.createKey(bucket, UUID.randomUUID().toString(), ReplicationConfig
683+
.fromTypeAndFactor(ReplicationType.RATIS, ReplicationFactor.ONE)
684+
, "content".getBytes(StandardCharsets.UTF_8));
685+
TestDataUtil.createKey(bucket, UUID.randomUUID().toString(), ReplicationConfig
686+
.fromTypeAndFactor(ReplicationType.RATIS, ReplicationFactor.ONE),
682687
"content".getBytes(StandardCharsets.UTF_8));
683688

684689
snapshotDirName =

0 commit comments

Comments
 (0)
Please sign in to comment.