jintaoguan commented on a change in pull request #2773: URL: https://github.com/apache/hudi/pull/2773#discussion_r609161570
########## File path: hudi-utilities/src/test/java/org/apache/hudi/utilities/functional/TestHoodieDeltaStreamer.java ########## @@ -1013,26 +1014,22 @@ public void testHoodieAsyncClusteringJob() throws Exception { HoodieDeltaStreamer ds = new HoodieDeltaStreamer(cfg, jsc); deltaStreamerTestRunner(ds, cfg, (r) -> { TestHelpers.assertAtLeastNCommits(2, tableBasePath, dfs); + String scheduleClusteringInstantTime = HoodieActiveTimeline.createNewInstantTime(); Review comment: Sure I will make it compatible with the old usage mode. The behavior will be 1) if the user provides an instant time, we will use it to schedule clustering and return it to the user. 2) if the user doesn't provide an instant time, we will generate one and return it to the user. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org