addInstant(HoodieTableMetaClient metaClient, String instant, boolean deltaCommit,
diff --git a/hudi-common/src/test/java/org/apache/hudi/common/table/view/TestRocksDBBasedIncrementalFSViewSync.java b/hudi-common/src/test/java/org/apache/hudi/common/table/view/TestRocksDBBasedIncrementalFSViewSync.java
index 355224279..082277e71 100644
--- a/hudi-common/src/test/java/org/apache/hudi/common/table/view/TestRocksDBBasedIncrementalFSViewSync.java
+++ b/hudi-common/src/test/java/org/apache/hudi/common/table/view/TestRocksDBBasedIncrementalFSViewSync.java
@@ -22,6 +22,7 @@ import org.apache.hudi.common.table.HoodieTableMetaClient;
import org.apache.hudi.common.table.timeline.HoodieTimeline;
import java.io.IOException;
+import java.nio.file.Files;
/**
* Tests rocks db based incremental file system view sync {@link RocksDbBasedFileSystemView}.
@@ -31,7 +32,8 @@ public class TestRocksDBBasedIncrementalFSViewSync extends TestIncrementalFSView
@Override
protected SyncableFileSystemView getFileSystemView(HoodieTableMetaClient metaClient, HoodieTimeline timeline)
throws IOException {
+ String subdirPath = Files.createTempDirectory(tempDir, null).toAbsolutePath().toString();
return new RocksDbBasedFileSystemView(metaClient, timeline, FileSystemViewStorageConfig.newBuilder()
- .withRocksDBPath(folder.newFolder().getAbsolutePath()).withIncrementalTimelineSync(true).build());
+ .withRocksDBPath(subdirPath).withIncrementalTimelineSync(true).build());
}
}
diff --git a/hudi-common/src/test/java/org/apache/hudi/common/HoodieCommonTestHarness.java b/hudi-common/src/test/java/org/apache/hudi/common/testutils/HoodieCommonTestHarness.java
similarity index 90%
rename from hudi-common/src/test/java/org/apache/hudi/common/HoodieCommonTestHarness.java
rename to hudi-common/src/test/java/org/apache/hudi/common/testutils/HoodieCommonTestHarness.java
index 62527975e..4315b50ab 100644
--- a/hudi-common/src/test/java/org/apache/hudi/common/HoodieCommonTestHarness.java
+++ b/hudi-common/src/test/java/org/apache/hudi/common/testutils/HoodieCommonTestHarness.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package org.apache.hudi.common;
+package org.apache.hudi.common.testutils;
import org.apache.hudi.common.model.HoodieTableType;
import org.apache.hudi.common.model.HoodieTestUtils;
@@ -25,8 +25,7 @@ import org.apache.hudi.common.table.timeline.HoodieTimeline;
import org.apache.hudi.common.table.view.HoodieTableFileSystemView;
import org.apache.hudi.common.table.view.SyncableFileSystemView;
-import org.junit.Rule;
-import org.junit.rules.TemporaryFolder;
+import org.junit.jupiter.api.io.TempDir;
import java.io.IOException;
@@ -36,17 +35,15 @@ import java.io.IOException;
public class HoodieCommonTestHarness {
protected String basePath = null;
-
- @Rule
- public TemporaryFolder folder = new TemporaryFolder();
-
protected transient HoodieTableMetaClient metaClient;
+ @TempDir
+ public java.nio.file.Path tempDir;
/**
* Initializes basePath.
*/
protected void initPath() {
- this.basePath = folder.getRoot().getAbsolutePath();
+ this.basePath = tempDir.toAbsolutePath().toString();
}
/**
@@ -56,7 +53,7 @@ public class HoodieCommonTestHarness {
* @throws IOException
*/
protected void initMetaClient() throws IOException {
- metaClient = HoodieTestUtils.init(folder.getRoot().getAbsolutePath(), getTableType());
+ metaClient = HoodieTestUtils.init(tempDir.toAbsolutePath().toString(), getTableType());
basePath = metaClient.getBasePath();
}
diff --git a/hudi-common/src/test/java/org/apache/hudi/common/testutils/HoodieCommonTestHarnessJunit5.java b/hudi-common/src/test/java/org/apache/hudi/common/testutils/HoodieCommonTestHarnessJunit5.java
deleted file mode 100644
index ba250365e..000000000
--- a/hudi-common/src/test/java/org/apache/hudi/common/testutils/HoodieCommonTestHarnessJunit5.java
+++ /dev/null
@@ -1,52 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.hudi.common.testutils;
-
-import org.apache.hudi.common.model.HoodieTestUtils;
-import org.apache.hudi.common.table.HoodieTableMetaClient;
-
-import org.junit.jupiter.api.io.TempDir;
-
-import java.io.IOException;
-
-/**
- * The JUnit 5 version of {@link org.apache.hudi.common.HoodieCommonTestHarness}.
- *
- * To incrementally migrate test classes.
- */
-public class HoodieCommonTestHarnessJunit5 extends org.apache.hudi.common.HoodieCommonTestHarness {
-
- @TempDir
- public java.nio.file.Path tempDir;
-
- /**
- * Initializes basePath.
- */
- protected void initPath() {
- this.basePath = tempDir.toAbsolutePath().toString();
- }
-
- /**
- * Initializes an instance of {@link HoodieTableMetaClient} with a special table type specified by {@code getTableType()}.
- */
- protected void initMetaClient() throws IOException {
- metaClient = HoodieTestUtils.init(tempDir.toAbsolutePath().toString(), getTableType());
- basePath = metaClient.getBasePath();
- }
-}
diff --git a/hudi-common/src/test/java/org/apache/hudi/common/util/CompactionTestUtils.java b/hudi-common/src/test/java/org/apache/hudi/common/util/CompactionTestUtils.java
index 5f6338fe9..baf34e0b2 100644
--- a/hudi-common/src/test/java/org/apache/hudi/common/util/CompactionTestUtils.java
+++ b/hudi-common/src/test/java/org/apache/hudi/common/util/CompactionTestUtils.java
@@ -34,7 +34,6 @@ import org.apache.hudi.common.util.collection.Pair;
import org.apache.hudi.exception.HoodieIOException;
import org.apache.hadoop.fs.Path;
-import org.junit.Assert;
import java.io.IOException;
import java.util.Arrays;
@@ -49,6 +48,8 @@ import java.util.stream.Stream;
import static org.apache.hudi.common.model.HoodieTestUtils.DEFAULT_PARTITION_PATHS;
import static org.apache.hudi.common.table.timeline.HoodieTimeline.COMPACTION_ACTION;
import static org.apache.hudi.common.table.timeline.HoodieTimeline.DELTA_COMMIT_ACTION;
+import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.junit.jupiter.api.Assertions.assertNull;
/**
* The utility class to support testing compaction.
@@ -95,10 +96,11 @@ public class CompactionTestUtils {
List plans = CollectionUtils.createImmutableList(plan1, plan2, plan3, plan4);
IntStream.range(0, 4).boxed().forEach(idx -> {
if (expectedNumEntries.get(idx) > 0) {
- Assert.assertEquals("check if plan " + idx + " has exp entries", expectedNumEntries.get(idx).longValue(),
- plans.get(idx).getOperations().size());
+ assertEquals(expectedNumEntries.get(idx).longValue(),
+ plans.get(idx).getOperations().size(),
+ "check if plan " + idx + " has exp entries");
} else {
- Assert.assertNull("Plan " + idx + " has null ops", plans.get(idx).getOperations());
+ assertNull(plans.get(idx).getOperations(), "Plan " + idx + " has null ops");
}
});
@@ -110,7 +112,7 @@ public class CompactionTestUtils {
generateExpectedCompactionOperations(Arrays.asList(plan1, plan2, plan3, plan4), baseInstantsToCompaction);
// Ensure Compaction operations are fine.
- Assert.assertEquals(expPendingCompactionMap, pendingCompactionMap);
+ assertEquals(expPendingCompactionMap, pendingCompactionMap);
return expPendingCompactionMap;
}
diff --git a/hudi-common/src/test/java/org/apache/hudi/common/util/TestBase64CodecUtil.java b/hudi-common/src/test/java/org/apache/hudi/common/util/TestBase64CodecUtil.java
index e62df4024..9129a8c03 100644
--- a/hudi-common/src/test/java/org/apache/hudi/common/util/TestBase64CodecUtil.java
+++ b/hudi-common/src/test/java/org/apache/hudi/common/util/TestBase64CodecUtil.java
@@ -18,12 +18,13 @@
package org.apache.hudi.common.util;
-import org.junit.Assert;
-import org.junit.Test;
+import org.junit.jupiter.api.Test;
import java.nio.charset.StandardCharsets;
import java.util.UUID;
+import static org.junit.jupiter.api.Assertions.assertArrayEquals;
+
public class TestBase64CodecUtil {
@Test
@@ -39,7 +40,7 @@ public class TestBase64CodecUtil {
String encodeData = Base64CodecUtil.encode(originalData);
byte[] decodeData = Base64CodecUtil.decode(encodeData);
- Assert.assertArrayEquals(originalData, decodeData);
+ assertArrayEquals(originalData, decodeData);
}
}
diff --git a/hudi-common/src/test/java/org/apache/hudi/common/util/TestCompactionUtils.java b/hudi-common/src/test/java/org/apache/hudi/common/util/TestCompactionUtils.java
index 045aa9430..269301508 100644
--- a/hudi-common/src/test/java/org/apache/hudi/common/util/TestCompactionUtils.java
+++ b/hudi-common/src/test/java/org/apache/hudi/common/util/TestCompactionUtils.java
@@ -20,7 +20,6 @@ package org.apache.hudi.common.util;
import org.apache.hudi.avro.model.HoodieCompactionOperation;
import org.apache.hudi.avro.model.HoodieCompactionPlan;
-import org.apache.hudi.common.HoodieCommonTestHarness;
import org.apache.hudi.common.fs.FSUtils;
import org.apache.hudi.common.model.FileSlice;
import org.apache.hudi.common.model.HoodieBaseFile;
@@ -29,13 +28,13 @@ import org.apache.hudi.common.model.HoodieLogFile;
import org.apache.hudi.common.model.HoodieTableType;
import org.apache.hudi.common.table.HoodieTableMetaClient;
import org.apache.hudi.common.table.timeline.versioning.compaction.CompactionPlanMigrator;
+import org.apache.hudi.common.testutils.HoodieCommonTestHarness;
import org.apache.hudi.common.util.CompactionTestUtils.TestHoodieBaseFile;
import org.apache.hudi.common.util.collection.Pair;
import org.apache.hadoop.fs.Path;
-import org.junit.Assert;
-import org.junit.Before;
-import org.junit.Test;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
import java.io.IOException;
import java.util.Arrays;
@@ -52,6 +51,9 @@ import static org.apache.hudi.common.util.CompactionTestUtils.scheduleCompaction
import static org.apache.hudi.common.util.CompactionTestUtils.setupAndValidateCompactionOperations;
import static org.apache.hudi.common.util.CompactionUtils.COMPACTION_METADATA_VERSION_1;
import static org.apache.hudi.common.util.CompactionUtils.LATEST_COMPACTION_METADATA_VERSION;
+import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.junit.jupiter.api.Assertions.assertThrows;
+import static org.junit.jupiter.api.Assertions.assertTrue;
/**
* The utility class for testing compaction.
@@ -68,7 +70,7 @@ public class TestCompactionUtils extends HoodieCommonTestHarness {
};
private Function, Map> metricsCaptureFn = (partitionFileSlice) -> METRICS;
- @Before
+ @BeforeEach
public void init() throws IOException {
initMetaClient();
}
@@ -81,13 +83,13 @@ public class TestCompactionUtils extends HoodieCommonTestHarness {
CompactionPlanMigrator migrator = new CompactionPlanMigrator(metaClient);
HoodieCompactionPlan plan = inputAndPlan.getRight();
System.out.println("Plan=" + plan.getOperations());
- Assert.assertEquals(LATEST_COMPACTION_METADATA_VERSION, plan.getVersion());
+ assertEquals(LATEST_COMPACTION_METADATA_VERSION, plan.getVersion());
HoodieCompactionPlan oldPlan = migrator.migrateToVersion(plan, plan.getVersion(), COMPACTION_METADATA_VERSION_1);
// Check with older version of compaction plan
- Assert.assertEquals(COMPACTION_METADATA_VERSION_1, oldPlan.getVersion());
+ assertEquals(COMPACTION_METADATA_VERSION_1, oldPlan.getVersion());
testFileSlicesCompactionPlanEquality(inputAndPlan.getKey(), oldPlan);
HoodieCompactionPlan newPlan = migrator.upgradeToLatest(plan, plan.getVersion());
- Assert.assertEquals(LATEST_COMPACTION_METADATA_VERSION, newPlan.getVersion());
+ assertEquals(LATEST_COMPACTION_METADATA_VERSION, newPlan.getVersion());
testFileSlicesCompactionPlanEquality(inputAndPlan.getKey(), newPlan);
HoodieCompactionPlan latestPlan = migrator.migrateToVersion(oldPlan, oldPlan.getVersion(), newPlan.getVersion());
testFileSlicesCompactionPlanEquality(inputAndPlan.getKey(), latestPlan);
@@ -169,14 +171,14 @@ public class TestCompactionUtils extends HoodieCommonTestHarness {
// Convert to CompactionOperation
// Convert back to HoodieCompactionOperation and check for equality
List regeneratedOps = originalOps.stream()
- .map(CompactionUtils::buildCompactionOperation)
- .map(CompactionUtils::buildHoodieCompactionOperation)
- .collect(Collectors.toList());
- Assert.assertTrue("Transformation did get tested", originalOps.size() > 0);
- Assert.assertEquals("All fields set correctly in transformations", originalOps, regeneratedOps);
+ .map(CompactionUtils::buildCompactionOperation)
+ .map(CompactionUtils::buildHoodieCompactionOperation)
+ .collect(Collectors.toList());
+ assertTrue(originalOps.size() > 0, "Transformation did get tested");
+ assertEquals(originalOps, regeneratedOps, "All fields set correctly in transformations");
}
- @Test(expected = IllegalStateException.class)
+ @Test
public void testGetAllPendingCompactionOperationsWithDupFileId() throws IOException {
// Case where there is duplicate fileIds in compaction requests
HoodieCompactionPlan plan1 = createCompactionPlan(metaClient, "000", "001", 10, true, true);
@@ -187,8 +189,9 @@ public class TestCompactionUtils extends HoodieCommonTestHarness {
plan1.getOperations().get(0).setDataFilePath("bla");
scheduleCompaction(metaClient, "005", plan1);
metaClient = new HoodieTableMetaClient(metaClient.getHadoopConf(), basePath, true);
- Map> res =
- CompactionUtils.getAllPendingCompactionOperations(metaClient);
+ assertThrows(IllegalStateException.class, () -> {
+ CompactionUtils.getAllPendingCompactionOperations(metaClient);
+ });
}
@Test
@@ -230,7 +233,7 @@ public class TestCompactionUtils extends HoodieCommonTestHarness {
* @param plan Compaction Plan
*/
private void testFileSlicesCompactionPlanEquality(List> input, HoodieCompactionPlan plan) {
- Assert.assertEquals("All file-slices present", input.size(), plan.getOperations().size());
+ assertEquals(input.size(), plan.getOperations().size(), "All file-slices present");
IntStream.range(0, input.size()).boxed().forEach(idx -> testFileSliceCompactionOpEquality(input.get(idx).getValue(),
plan.getOperations().get(idx), input.get(idx).getKey(), plan.getVersion()));
}
@@ -244,19 +247,19 @@ public class TestCompactionUtils extends HoodieCommonTestHarness {
*/
private void testFileSliceCompactionOpEquality(FileSlice slice, HoodieCompactionOperation op, String expPartitionPath,
int version) {
- Assert.assertEquals("Partition path is correct", expPartitionPath, op.getPartitionPath());
- Assert.assertEquals("Same base-instant", slice.getBaseInstantTime(), op.getBaseInstantTime());
- Assert.assertEquals("Same file-id", slice.getFileId(), op.getFileId());
+ assertEquals(expPartitionPath, op.getPartitionPath(), "Partition path is correct");
+ assertEquals(slice.getBaseInstantTime(), op.getBaseInstantTime(), "Same base-instant");
+ assertEquals(slice.getFileId(), op.getFileId(), "Same file-id");
if (slice.getBaseFile().isPresent()) {
HoodieBaseFile df = slice.getBaseFile().get();
- Assert.assertEquals("Same data-file", version == COMPACTION_METADATA_VERSION_1 ? df.getPath() : df.getFileName(),
- op.getDataFilePath());
+ assertEquals(version == COMPACTION_METADATA_VERSION_1 ? df.getPath() : df.getFileName(),
+ op.getDataFilePath(), "Same data-file");
}
List paths = slice.getLogFiles().map(l -> l.getPath().toString()).collect(Collectors.toList());
- IntStream.range(0, paths.size()).boxed().forEach(idx -> Assert.assertEquals("Log File Index " + idx,
+ IntStream.range(0, paths.size()).boxed().forEach(idx -> assertEquals(
version == COMPACTION_METADATA_VERSION_1 ? paths.get(idx) : new Path(paths.get(idx)).getName(),
- op.getDeltaFilePaths().get(idx)));
- Assert.assertEquals("Metrics set", METRICS, op.getMetrics());
+ op.getDeltaFilePaths().get(idx), "Log File Index " + idx));
+ assertEquals(METRICS, op.getMetrics(), "Metrics set");
}
@Override
diff --git a/hudi-common/src/test/java/org/apache/hudi/common/util/TestDFSPropertiesConfiguration.java b/hudi-common/src/test/java/org/apache/hudi/common/util/TestDFSPropertiesConfiguration.java
index 6a06d7ddc..792eded41 100644
--- a/hudi-common/src/test/java/org/apache/hudi/common/util/TestDFSPropertiesConfiguration.java
+++ b/hudi-common/src/test/java/org/apache/hudi/common/util/TestDFSPropertiesConfiguration.java
@@ -25,17 +25,17 @@ import org.apache.hudi.common.minicluster.HdfsTestService;
import org.apache.hadoop.fs.Path;
import org.apache.hadoop.hdfs.DistributedFileSystem;
import org.apache.hadoop.hdfs.MiniDFSCluster;
-import org.junit.AfterClass;
-import org.junit.BeforeClass;
-import org.junit.Test;
+import org.junit.jupiter.api.AfterAll;
+import org.junit.jupiter.api.BeforeAll;
+import org.junit.jupiter.api.Test;
import java.io.IOException;
import java.io.PrintStream;
-import static org.junit.Assert.assertEquals;
-import static org.junit.Assert.assertFalse;
-import static org.junit.Assert.assertTrue;
-import static org.junit.Assert.fail;
+import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.junit.jupiter.api.Assertions.assertFalse;
+import static org.junit.jupiter.api.Assertions.assertThrows;
+import static org.junit.jupiter.api.Assertions.assertTrue;
/**
* Tests basic functionality of {@link DFSPropertiesConfiguration}.
@@ -47,7 +47,7 @@ public class TestDFSPropertiesConfiguration {
private static MiniDFSCluster dfsCluster;
private static DistributedFileSystem dfs;
- @BeforeClass
+ @BeforeAll
public static void initClass() throws Exception {
hdfsTestService = new HdfsTestService();
dfsCluster = hdfsTestService.start(true);
@@ -72,7 +72,7 @@ public class TestDFSPropertiesConfiguration {
writePropertiesFile(filePath, new String[] {"double.prop=838.3", "include = t4.props"});
}
- @AfterClass
+ @AfterAll
public static void cleanupClass() throws Exception {
if (hdfsTestService != null) {
hdfsTestService.stop();
@@ -93,12 +93,9 @@ public class TestDFSPropertiesConfiguration {
DFSPropertiesConfiguration cfg = new DFSPropertiesConfiguration(dfs, new Path(dfsBasePath + "/t1.props"));
TypedProperties props = cfg.getConfig();
assertEquals(5, props.size());
- try {
+ assertThrows(IllegalArgumentException.class, () -> {
props.getString("invalid.key");
- fail("Should error out here.");
- } catch (IllegalArgumentException iae) {
- // ignore
- }
+ }, "Should error out here.");
assertEquals(123, props.getInteger("int.prop"));
assertEquals(113.4, props.getDouble("double.prop"), 0.001);
@@ -129,12 +126,8 @@ public class TestDFSPropertiesConfiguration {
assertTrue(props.getBoolean("boolean.prop"));
assertEquals("t3.value", props.getString("string.prop"));
assertEquals(1354354354, props.getLong("long.prop"));
-
- try {
+ assertThrows(IllegalStateException.class, () -> {
new DFSPropertiesConfiguration(dfs, new Path(dfsBasePath + "/t4.props"));
- fail("Should error out on a self-included file.");
- } catch (IllegalStateException ise) {
- // ignore
- }
+ }, "Should error out on a self-included file.");
}
}
diff --git a/hudi-common/src/test/java/org/apache/hudi/common/util/TestFileIOUtils.java b/hudi-common/src/test/java/org/apache/hudi/common/util/TestFileIOUtils.java
index 5292f07a6..0c2ac7cf6 100644
--- a/hudi-common/src/test/java/org/apache/hudi/common/util/TestFileIOUtils.java
+++ b/hudi-common/src/test/java/org/apache/hudi/common/util/TestFileIOUtils.java
@@ -18,7 +18,7 @@
package org.apache.hudi.common.util;
-import org.apache.hudi.common.testutils.HoodieCommonTestHarnessJunit5;
+import org.apache.hudi.common.testutils.HoodieCommonTestHarness;
import org.junit.jupiter.api.Test;
@@ -35,7 +35,7 @@ import static org.junit.jupiter.api.Assertions.fail;
/**
* Tests file I/O utils.
*/
-public class TestFileIOUtils extends HoodieCommonTestHarnessJunit5 {
+public class TestFileIOUtils extends HoodieCommonTestHarness {
@Test
public void testMkdirAndDelete() throws IOException {
diff --git a/hudi-common/src/test/java/org/apache/hudi/common/util/TestNumericUtils.java b/hudi-common/src/test/java/org/apache/hudi/common/util/TestNumericUtils.java
index cd76383f6..9a74b63c6 100644
--- a/hudi-common/src/test/java/org/apache/hudi/common/util/TestNumericUtils.java
+++ b/hudi-common/src/test/java/org/apache/hudi/common/util/TestNumericUtils.java
@@ -18,12 +18,12 @@
package org.apache.hudi.common.util;
-import org.junit.Test;
+import org.junit.jupiter.api.Test;
import java.util.Arrays;
-import static org.junit.Assert.assertEquals;
-import static org.junit.Assert.assertNotEquals;
+import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.junit.jupiter.api.Assertions.assertNotEquals;
/**
* Tests numeric utils.
diff --git a/hudi-common/src/test/java/org/apache/hudi/common/util/TestParquetUtils.java b/hudi-common/src/test/java/org/apache/hudi/common/util/TestParquetUtils.java
index 58c4580de..2d2084d5a 100644
--- a/hudi-common/src/test/java/org/apache/hudi/common/util/TestParquetUtils.java
+++ b/hudi-common/src/test/java/org/apache/hudi/common/util/TestParquetUtils.java
@@ -20,12 +20,12 @@ package org.apache.hudi.common.util;
import org.apache.hudi.avro.HoodieAvroUtils;
import org.apache.hudi.avro.HoodieAvroWriteSupport;
-import org.apache.hudi.common.HoodieCommonTestHarness;
import org.apache.hudi.common.bloom.BloomFilter;
import org.apache.hudi.common.bloom.BloomFilterFactory;
import org.apache.hudi.common.bloom.BloomFilterTypeCode;
import org.apache.hudi.common.model.HoodieRecord;
import org.apache.hudi.common.model.HoodieTestUtils;
+import org.apache.hudi.common.testutils.HoodieCommonTestHarness;
import org.apache.avro.Schema;
import org.apache.avro.generic.GenericData;
@@ -34,58 +34,50 @@ import org.apache.hadoop.fs.Path;
import org.apache.parquet.avro.AvroSchemaConverter;
import org.apache.parquet.hadoop.ParquetWriter;
import org.apache.parquet.hadoop.metadata.CompressionCodecName;
-import org.junit.Before;
-import org.junit.Test;
-import org.junit.runner.RunWith;
-import org.junit.runners.Parameterized;
-import org.junit.runners.Parameterized.Parameters;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.params.ParameterizedTest;
+import org.junit.jupiter.params.provider.Arguments;
+import org.junit.jupiter.params.provider.MethodSource;
+import java.nio.file.Paths;
import java.util.ArrayList;
import java.util.Arrays;
-import java.util.Collection;
import java.util.Collections;
import java.util.HashSet;
import java.util.List;
import java.util.Set;
import java.util.UUID;
-import static org.junit.Assert.assertEquals;
-import static org.junit.Assert.assertTrue;
+import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.junit.jupiter.api.Assertions.assertTrue;
/**
* Tests parquet utils.
*/
-@RunWith(Parameterized.class)
public class TestParquetUtils extends HoodieCommonTestHarness {
- String bloomFilterTypeToTest;
-
- @Parameters()
- public static Collection