jintaoguan commented on a change in pull request #2773:
URL: https://github.com/apache/hudi/pull/2773#discussion_r608427661
##########
File path:
hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieClusteringJob.java
##########
@@ -156,15 +155,15 @@ private int doCluster(JavaSparkContext jsc) throws
Exception {
}
@TestOnly
- public Option<String> doSchedule() throws Exception {
Review comment:
The schedule instant time is already in `HoodieClusteringJob.Config`.
If `doSchedule()` succeeds and returns 0, we should be able to get the
clustering instant time from the config.
I am trying to use the same patern as `doSchedule()` of `HoodieCompactor`.
Correct me if I misunderstand it.
--
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]
