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:
[email protected]
