[hudi] branch master updated: [MINOR] Fixing test failure to fix CI build failure (#4132)

[si...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

sivabalan pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git


The following commit(s) were added to refs/heads/master by this push:
     new a88691f  [MINOR] Fixing test failure to fix CI build failure (#4132)
a88691f is described below

commit a88691fed38cc7b8a1f26bfcbb9a7504a0acdd8d
Author: Sivabalan Narayanan <si...@uber.com>
AuthorDate: Fri Nov 26 13:50:10 2021 -0500

    [MINOR] Fixing test failure to fix CI build failure (#4132)
---
 .../java/org/apache/hudi/client/TestHoodieClientMultiWriter.java   | 7 +++----
 1 file changed, 3 insertions(+), 4 deletions(-)

diff --git a/hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/client/TestHoodieClientMultiWriter.java b/hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/client/TestHoodieClientMultiWriter.java
index afc4cae..ced525c 100644
--- a/hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/client/TestHoodieClientMultiWriter.java
+++ b/hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/client/TestHoodieClientMultiWriter.java
@@ -58,7 +58,6 @@ import java.util.concurrent.Future;
 import java.util.stream.Collectors;
 
 import static org.apache.hudi.common.config.LockConfiguration.FILESYSTEM_LOCK_PATH_PROP_KEY;
-import static org.junit.jupiter.api.Assertions.assertFalse;
 import static org.junit.jupiter.api.Assertions.assertTrue;
 import static org.junit.jupiter.api.Assertions.fail;
 
@@ -345,16 +344,16 @@ public class TestHoodieClientMultiWriter extends HoodieClientTestBase {
         numRecords, 200, 2);
     // Start and finish another commit while the previous writer for commit 003 is running
     newCommitTime = "004";
-    SparkRDDWriteClient client2 = getHoodieWriteClient(cfg2);
+    SparkRDDWriteClient client2 = getHoodieWriteClient(cfg);
     JavaRDD<WriteStatus> result2 = updateBatch(cfg2, client2, newCommitTime, "001",
         Option.of(Arrays.asList(commitTimeBetweenPrevAndNew)), "000", numRecords, SparkRDDWriteClient::upsert, false, false,
         numRecords, 200, 2);
     client2.commit(newCommitTime, result2);
     // Schedule and run clustering while previous writer for commit 003 is running
-    SparkRDDWriteClient client3 = getHoodieWriteClient(cfg);
+    SparkRDDWriteClient client3 = getHoodieWriteClient(cfg2);
     // schedule clustering
     Option<String> clusterInstant = client3.scheduleTableService(Option.empty(), TableServiceType.CLUSTER);
-    assertFalse(clusterInstant.isPresent());
+    assertTrue(clusterInstant.isPresent());
     // Attempt to commit the inflight commit 003
     try {
       client1.commit("003", result1);