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 fe040c9432000..85b5743f4a4a6 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 void testSimpleTagLocationWithInvalidCommit() throws Exception { 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();