Skip to content

Commit 4c110c1

Browse files
authored
[HUDI-5070] Adding lock provider to testCleaner tests since async cleaning is invoked (#7023)
1 parent 9c3b57c commit 4c110c1

1 file changed

Lines changed: 3 additions & 0 deletions

File tree

  • hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/table

hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/table/TestCleaner.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -31,6 +31,7 @@
3131
import org.apache.hudi.avro.model.HoodieSliceInfo;
3232
import org.apache.hudi.client.SparkRDDWriteClient;
3333
import org.apache.hudi.client.WriteStatus;
34+
import org.apache.hudi.client.transaction.lock.InProcessLockProvider;
3435
import org.apache.hudi.common.HoodieCleanStat;
3536
import org.apache.hudi.common.bootstrap.TestBootstrapIndex;
3637
import org.apache.hudi.common.config.HoodieMetadataConfig;
@@ -72,6 +73,7 @@
7273
import org.apache.hudi.common.util.collection.Pair;
7374
import org.apache.hudi.config.HoodieCleanConfig;
7475
import org.apache.hudi.config.HoodieCompactionConfig;
76+
import org.apache.hudi.config.HoodieLockConfig;
7577
import org.apache.hudi.config.HoodieWriteConfig;
7678
import org.apache.hudi.exception.HoodieIOException;
7779
import org.apache.hudi.index.HoodieIndex;
@@ -519,6 +521,7 @@ private void testInsertAndCleanByCommits(
519521
.withCleanerPolicy(HoodieCleaningPolicy.KEEP_LATEST_COMMITS).withAsyncClean(isAsync).retainCommits(maxCommits).build())
520522
.withParallelism(1, 1).withBulkInsertParallelism(1).withFinalizeWriteParallelism(1).withDeleteParallelism(1)
521523
.withConsistencyGuardConfig(ConsistencyGuardConfig.newBuilder().withConsistencyCheckEnabled(true).build())
524+
.withLockConfig(HoodieLockConfig.newBuilder().withLockProvider(InProcessLockProvider.class).build())
522525
.build();
523526
SparkRDDWriteClient client = getHoodieWriteClient(cfg);
524527

0 commit comments

Comments
 (0)