diff --git a/hudi-client/src/test/java/org/apache/hudi/io/strategy/TestHoodieCompactionStrategy.java b/hudi-client/src/test/java/org/apache/hudi/io/strategy/TestHoodieCompactionStrategy.java index 86447f33b..5eda0b2c9 100644 --- a/hudi-client/src/test/java/org/apache/hudi/io/strategy/TestHoodieCompactionStrategy.java +++ b/hudi-client/src/test/java/org/apache/hudi/io/strategy/TestHoodieCompactionStrategy.java @@ -53,6 +53,7 @@ public class TestHoodieCompactionStrategy { private static final long MB = 1024 * 1024L; private String[] partitionPaths = {"2017/01/01", "2017/01/02", "2017/01/03"}; + private static final Random RANDOM = new Random(); @Test public void testUnBounded() { @@ -228,7 +229,7 @@ public class TestHoodieCompactionStrategy { private List createCompactionOperations(HoodieWriteConfig config, Map> sizesMap) { Map keyToPartitionMap = sizesMap.keySet().stream() - .map(e -> Pair.of(e, partitionPaths[new Random().nextInt(partitionPaths.length - 1)])) + .map(e -> Pair.of(e, partitionPaths[RANDOM.nextInt(partitionPaths.length - 1)])) .collect(Collectors.toMap(Pair::getKey, Pair::getValue)); return createCompactionOperations(config, sizesMap, keyToPartitionMap); } diff --git a/hudi-utilities/src/test/java/org/apache/hudi/utilities/TestHoodieDeltaStreamer.java b/hudi-utilities/src/test/java/org/apache/hudi/utilities/TestHoodieDeltaStreamer.java index 36ebb41ca..ed45346f4 100644 --- a/hudi-utilities/src/test/java/org/apache/hudi/utilities/TestHoodieDeltaStreamer.java +++ b/hudi-utilities/src/test/java/org/apache/hudi/utilities/TestHoodieDeltaStreamer.java @@ -93,6 +93,7 @@ import static org.junit.Assert.fail; */ public class TestHoodieDeltaStreamer extends UtilitiesTestBase { + private static final Random RANDOM = new Random(); private static final String PROPS_FILENAME_TEST_SOURCE = "test-source.properties"; private static final String PROPS_FILENAME_TEST_INVALID = "test-invalid.properties"; private static final Logger LOG = LogManager.getLogger(TestHoodieDeltaStreamer.class); @@ -634,7 +635,7 @@ public class TestHoodieDeltaStreamer extends UtilitiesTestBase { */ @Override public Double call(Double lat1, Double lat2, Double lon1, Double lon2) { - return new Random().nextDouble(); + return RANDOM.nextDouble(); } }