diff --git a/hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/index/hbase/TestHBaseIndex.java b/hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/index/hbase/TestHBaseIndex.java index fe040c943..85b5743f4 100644 --- a/hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/index/hbase/TestHBaseIndex.java +++ b/hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/index/hbase/TestHBaseIndex.java @@ -324,7 +324,7 @@ public class TestHBaseIndex extends FunctionalTestHarness { String newCommitTime = writeClient.startCommit(); // make a commit with 199 records - JavaRDD writeRecords = generateAndCommitRecords(writeClient, 199); + JavaRDD writeRecords = generateAndCommitRecords(writeClient, 199, newCommitTime); // make a second commit with a single record String invalidCommit = writeClient.startCommit();