You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hudi.apache.org by GitBox <gi...@apache.org> on 2022/09/07 02:24:43 UTC
[GitHub] [hudi] eric9204 commented on a diff in pull request #6574: Keep a clustering running at the same time.#6573
eric9204 commented on code in PR #6574:
URL: https://github.com/apache/hudi/pull/6574#discussion_r963258228
##########
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/cluster/ClusteringPlanActionExecutor.java:
##########
@@ -77,11 +78,14 @@ protected Option<HoodieClusteringPlan> createClusteringPlan() {
return Option.empty();
}
- LOG.info("Generating clustering plan for table " + config.getBasePath());
- ClusteringPlanStrategy strategy = (ClusteringPlanStrategy)
- ReflectionUtils.loadClass(ClusteringPlanStrategy.checkAndGetClusteringPlanStrategy(config), table, context, config);
+ ClusteringPlanStrategy strategy = null;
+ if (config.getAsyncClusterMaxCommits() <= commitsSinceLastClustering) {
+ LOG.info("Generating clustering plan for table " + config.getBasePath());
+ strategy = (ClusteringPlanStrategy)
+ ReflectionUtils.loadClass(ClusteringPlanStrategy.checkAndGetClusteringPlanStrategy(config), table, context, config);
+ }
- return strategy.generateClusteringPlan();
+ return strategy == null ? Option.empty() : strategy.generateClusteringPlan();
Review Comment:
@yihua yes, because my last commit deleted the following condition,which can avoid the frequent clustering scheduling.
```
if (table.getActiveTimeline().filterPendingReplaceTimeline().countInstants() != 0) {
LOG.info("The last clustering is running,there is no need to generate a new clustering plan" + config.getBasePath());
return Option.empty();
}
```
##########
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/cluster/ClusteringPlanActionExecutor.java:
##########
@@ -63,6 +63,7 @@ protected Option<HoodieClusteringPlan> createClusteringPlan() {
int commitsSinceLastClustering = table.getActiveTimeline().getCommitsTimeline().filterCompletedInstants()
.findInstantsAfter(lastClusteringInstant.map(HoodieInstant::getTimestamp).orElse("0"), Integer.MAX_VALUE)
.countInstants();
+
if (config.inlineClusteringEnabled() && config.getInlineClusterMaxCommits() > commitsSinceLastClustering) {
Review Comment:
@yihua yes, this is indeed a redundant inspection, I'm testing whether this condition is needed.
By adding these two conditions, it can really be guaranteed that only one clustering is running at the same time, and if there is no completed clustering, no new clustering plan will be generated.
Configure only these three parameters.
'clustering.schedule.enabled'='true',
'clustering.async.enabled'='false',
'clustering.delta_commits'='6',
```
0 2022-09-02 10:38 /tmp/hudi/insert_cow_clustering_12_state_1/.hoodie/.aux
0 2022-09-02 10:38 /tmp/hudi/insert_cow_clustering_12_state_1/.hoodie/.schema
0 2022-09-02 10:41 /tmp/hudi/insert_cow_clustering_12_state_1/.hoodie/.temp
2.6 K 2022-09-02 10:39 /tmp/hudi/insert_cow_clustering_12_state_1/.hoodie/20220902103807454.commit
0 2022-09-02 10:39 /tmp/hudi/insert_cow_clustering_12_state_1/.hoodie/20220902103807454.commit.requested
0 2022-09-02 10:39 /tmp/hudi/insert_cow_clustering_12_state_1/.hoodie/20220902103807454.inflight
2.6 K 2022-09-02 10:39 /tmp/hudi/insert_cow_clustering_12_state_1/.hoodie/20220902103813399.commit
0 2022-09-02 10:39 /tmp/hudi/insert_cow_clustering_12_state_1/.hoodie/20220902103813399.commit.requested
0 2022-09-02 10:39 /tmp/hudi/insert_cow_clustering_12_state_1/.hoodie/20220902103813399.inflight
2.6 K 2022-09-02 10:39 /tmp/hudi/insert_cow_clustering_12_state_1/.hoodie/20220902103823232.commit
0 2022-09-02 10:39 /tmp/hudi/insert_cow_clustering_12_state_1/.hoodie/20220902103823232.commit.requested
0 2022-09-02 10:39 /tmp/hudi/insert_cow_clustering_12_state_1/.hoodie/20220902103823232.inflight
2.6 K 2022-09-02 10:39 /tmp/hudi/insert_cow_clustering_12_state_1/.hoodie/20220902103833587.commit
0 2022-09-02 10:39 /tmp/hudi/insert_cow_clustering_12_state_1/.hoodie/20220902103833587.commit.requested
0 2022-09-02 10:39 /tmp/hudi/insert_cow_clustering_12_state_1/.hoodie/20220902103833587.inflight
2.6 K 2022-09-02 10:39 /tmp/hudi/insert_cow_clustering_12_state_1/.hoodie/20220902103842538.commit
0 2022-09-02 10:39 /tmp/hudi/insert_cow_clustering_12_state_1/.hoodie/20220902103842538.commit.requested
0 2022-09-02 10:39 /tmp/hudi/insert_cow_clustering_12_state_1/.hoodie/20220902103842538.inflight
2.6 K 2022-09-02 10:39 /tmp/hudi/insert_cow_clustering_12_state_1/.hoodie/20220902103856152.commit
0 2022-09-02 10:39 /tmp/hudi/insert_cow_clustering_12_state_1/.hoodie/20220902103856152.commit.requested
0 2022-09-02 10:39 /tmp/hudi/insert_cow_clustering_12_state_1/.hoodie/20220902103856152.inflight
3.8 K 2022-09-02 10:39 /tmp/hudi/insert_cow_clustering_12_state_1/.hoodie/20220902103902693.replacecommit.requested
2.6 K 2022-09-02 10:40 /tmp/hudi/insert_cow_clustering_12_state_1/.hoodie/20220902103902852.commit
0 2022-09-02 10:39 /tmp/hudi/insert_cow_clustering_12_state_1/.hoodie/20220902103902852.commit.requested
0 2022-09-02 10:39 /tmp/hudi/insert_cow_clustering_12_state_1/.hoodie/20220902103902852.inflight
2.6 K 2022-09-02 10:40 /tmp/hudi/insert_cow_clustering_12_state_1/.hoodie/20220902103912533.commit
0 2022-09-02 10:40 /tmp/hudi/insert_cow_clustering_12_state_1/.hoodie/20220902103912533.commit.requested
0 2022-09-02 10:40 /tmp/hudi/insert_cow_clustering_12_state_1/.hoodie/20220902103912533.inflight
2.6 K 2022-09-02 10:40 /tmp/hudi/insert_cow_clustering_12_state_1/.hoodie/20220902103922361.commit
0 2022-09-02 10:40 /tmp/hudi/insert_cow_clustering_12_state_1/.hoodie/20220902103922361.commit.requested
0 2022-09-02 10:40 /tmp/hudi/insert_cow_clustering_12_state_1/.hoodie/20220902103922361.inflight
2.6 K 2022-09-02 10:40 /tmp/hudi/insert_cow_clustering_12_state_1/.hoodie/20220902103932640.commit
0 2022-09-02 10:40 /tmp/hudi/insert_cow_clustering_12_state_1/.hoodie/20220902103932640.commit.requested
0 2022-09-02 10:40 /tmp/hudi/insert_cow_clustering_12_state_1/.hoodie/20220902103932640.inflight
2.6 K 2022-09-02 10:40 /tmp/hudi/insert_cow_clustering_12_state_1/.hoodie/20220902103943515.commit
0 2022-09-02 10:40 /tmp/hudi/insert_cow_clustering_12_state_1/.hoodie/20220902103943515.commit.requested
0 2022-09-02 10:40 /tmp/hudi/insert_cow_clustering_12_state_1/.hoodie/20220902103943515.inflight
2.6 K 2022-09-02 10:40 /tmp/hudi/insert_cow_clustering_12_state_1/.hoodie/20220902103952954.commit
0 2022-09-02 10:40 /tmp/hudi/insert_cow_clustering_12_state_1/.hoodie/20220902103952954.commit.requested
0 2022-09-02 10:40 /tmp/hudi/insert_cow_clustering_12_state_1/.hoodie/20220902103952954.inflight
2.6 K 2022-09-02 10:41 /tmp/hudi/insert_cow_clustering_12_state_1/.hoodie/20220902104004110.commit
0 2022-09-02 10:40 /tmp/hudi/insert_cow_clustering_12_state_1/.hoodie/20220902104004110.commit.requested
0 2022-09-02 10:40 /tmp/hudi/insert_cow_clustering_12_state_1/.hoodie/20220902104004110.inflight
2.6 K 2022-09-02 10:41 /tmp/hudi/insert_cow_clustering_12_state_1/.hoodie/20220902104013404.commit
0 2022-09-02 10:41 /tmp/hudi/insert_cow_clustering_12_state_1/.hoodie/20220902104013404.commit.requested
0 2022-09-02 10:41 /tmp/hudi/insert_cow_clustering_12_state_1/.hoodie/20220902104013404.inflight
2.6 K 2022-09-02 10:41 /tmp/hudi/insert_cow_clustering_12_state_1/.hoodie/20220902104022645.commit
0 2022-09-02 10:41 /tmp/hudi/insert_cow_clustering_12_state_1/.hoodie/20220902104022645.commit.requested
0 2022-09-02 10:41 /tmp/hudi/insert_cow_clustering_12_state_1/.hoodie/20220902104022645.inflight
2.6 K 2022-09-02 10:41 /tmp/hudi/insert_cow_clustering_12_state_1/.hoodie/20220902104032517.commit
0 2022-09-02 10:41 /tmp/hudi/insert_cow_clustering_12_state_1/.hoodie/20220902104032517.commit.requested
0 2022-09-02 10:41 /tmp/hudi/insert_cow_clustering_12_state_1/.hoodie/20220902104032517.inflight
2.6 K 2022-09-02 10:41 /tmp/hudi/insert_cow_clustering_12_state_1/.hoodie/20220902104042885.commit
0 2022-09-02 10:41 /tmp/hudi/insert_cow_clustering_12_state_1/.hoodie/20220902104042885.commit.requested
0 2022-09-02 10:41 /tmp/hudi/insert_cow_clustering_12_state_1/.hoodie/20220902104042885.inflight
2.6 K 2022-09-02 10:41 /tmp/hudi/insert_cow_clustering_12_state_1/.hoodie/20220902104052515.commit
0 2022-09-02 10:41 /tmp/hudi/insert_cow_clustering_12_state_1/.hoodie/20220902104052515.commit.requested
0 2022-09-02 10:41 /tmp/hudi/insert_cow_clustering_12_state_1/.hoodie/20220902104052515.inflight
0 2022-09-02 10:41 /tmp/hudi/insert_cow_clustering_12_state_1/.hoodie/20220902104105238.commit.requested
0 2022-09-02 10:41 /tmp/hudi/insert_cow_clustering_12_state_1/.hoodie/20220902104105238.inflight
0 2022-09-02 10:38 /tmp/hudi/insert_cow_clustering_12_state_1/.hoodie/archived
1005 2022-09-02 10:38 /tmp/hudi/insert_cow_clustering_12_state_1/.hoodie/hoodie.properties
```
Configure only these three parameters.
'clustering.schedule.enabled'='true',
'clustering.async.enabled'='true',
'clustering.delta_commits'='6',
```
0 2022-09-02 10:30 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/.aux
0 2022-09-02 10:30 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/.schema
0 2022-09-02 10:37 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/.temp
2.6 K 2022-09-02 10:31 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103029577.commit
0 2022-09-02 10:31 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103029577.commit.requested
0 2022-09-02 10:31 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103029577.inflight
2.6 K 2022-09-02 10:31 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103038501.commit
0 2022-09-02 10:31 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103038501.commit.requested
0 2022-09-02 10:31 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103038501.inflight
2.6 K 2022-09-02 10:31 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103046820.commit
0 2022-09-02 10:31 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103046820.commit.requested
0 2022-09-02 10:31 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103046820.inflight
2.6 K 2022-09-02 10:31 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103056890.commit
0 2022-09-02 10:31 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103056890.commit.requested
0 2022-09-02 10:31 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103056890.inflight
2.6 K 2022-09-02 10:32 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103106350.commit
0 2022-09-02 10:32 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103106350.commit.requested
0 2022-09-02 10:32 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103106350.inflight
2.6 K 2022-09-02 10:32 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103116318.commit
0 2022-09-02 10:32 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103116318.commit.requested
0 2022-09-02 10:32 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103116318.inflight
2.9 K 2022-09-02 10:33 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103126473.replacecommit
0 2022-09-02 10:32 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103126473.replacecommit.inflight
3.8 K 2022-09-02 10:32 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103126473.replacecommit.requested
2.6 K 2022-09-02 10:32 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103128014.commit
0 2022-09-02 10:32 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103128014.commit.requested
0 2022-09-02 10:32 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103128014.inflight
2.6 K 2022-09-02 10:32 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103136075.commit
0 2022-09-02 10:32 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103136075.commit.requested
0 2022-09-02 10:32 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103136075.inflight
2.6 K 2022-09-02 10:32 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103146039.commit
0 2022-09-02 10:32 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103146039.commit.requested
0 2022-09-02 10:32 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103146039.inflight
2.6 K 2022-09-02 10:33 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103156252.commit
0 2022-09-02 10:32 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103156252.commit.requested
0 2022-09-02 10:32 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103156252.inflight
2.6 K 2022-09-02 10:33 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103208166.commit
0 2022-09-02 10:33 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103208166.commit.requested
0 2022-09-02 10:33 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103208166.inflight
2.6 K 2022-09-02 10:33 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103217149.commit
0 2022-09-02 10:33 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103217149.commit.requested
0 2022-09-02 10:33 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103217149.inflight
2.9 K 2022-09-02 10:34 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103226275.replacecommit
0 2022-09-02 10:33 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103226275.replacecommit.inflight
4.0 K 2022-09-02 10:33 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103226275.replacecommit.requested
2.6 K 2022-09-02 10:33 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103226480.commit
0 2022-09-02 10:33 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103226480.commit.requested
0 2022-09-02 10:33 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103226480.inflight
2.6 K 2022-09-02 10:33 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103236458.commit
0 2022-09-02 10:33 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103236458.commit.requested
0 2022-09-02 10:33 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103236458.inflight
2.6 K 2022-09-02 10:33 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103246596.commit
0 2022-09-02 10:33 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103246596.commit.requested
0 2022-09-02 10:33 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103246596.inflight
2.6 K 2022-09-02 10:33 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103256288.commit
0 2022-09-02 10:33 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103256288.commit.requested
0 2022-09-02 10:33 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103256288.inflight
2.2 K 2022-09-02 10:33 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103257588.clean
2.4 K 2022-09-02 10:33 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103257588.clean.inflight
2.4 K 2022-09-02 10:33 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103257588.clean.requested
2.6 K 2022-09-02 10:34 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103306174.commit
0 2022-09-02 10:33 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103306174.commit.requested
0 2022-09-02 10:33 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103306174.inflight
2.6 K 2022-09-02 10:34 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103316779.commit
0 2022-09-02 10:34 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103316779.commit.requested
0 2022-09-02 10:34 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103316779.inflight
2.6 K 2022-09-02 10:34 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103327090.commit
0 2022-09-02 10:34 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103327090.commit.requested
0 2022-09-02 10:34 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103327090.inflight
2.6 K 2022-09-02 10:34 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103336441.commit
0 2022-09-02 10:34 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103336441.commit.requested
0 2022-09-02 10:34 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103336441.inflight
3.0 K 2022-09-02 10:36 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103346469.replacecommit
0 2022-09-02 10:34 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103346469.replacecommit.inflight
4.4 K 2022-09-02 10:34 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103346469.replacecommit.requested
2.6 K 2022-09-02 10:34 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103346978.commit
0 2022-09-02 10:34 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103346978.commit.requested
0 2022-09-02 10:34 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103346978.inflight
2.6 K 2022-09-02 10:34 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103356123.commit
0 2022-09-02 10:34 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103356123.commit.requested
0 2022-09-02 10:34 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103356123.inflight
2.6 K 2022-09-02 10:35 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103406453.commit
0 2022-09-02 10:35 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103406453.commit.requested
0 2022-09-02 10:35 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103406453.inflight
2.6 K 2022-09-02 10:35 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103417218.commit
0 2022-09-02 10:35 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103417218.commit.requested
0 2022-09-02 10:35 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103417218.inflight
2.4 K 2022-09-02 10:34 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103427314.clean
2.5 K 2022-09-02 10:34 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103427314.clean.inflight
2.5 K 2022-09-02 10:34 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103427314.clean.requested
2.6 K 2022-09-02 10:35 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103427491.commit
0 2022-09-02 10:35 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103427491.commit.requested
0 2022-09-02 10:35 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103427491.inflight
2.6 K 2022-09-02 10:35 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103438027.commit
0 2022-09-02 10:35 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103438027.commit.requested
0 2022-09-02 10:35 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103438027.inflight
2.6 K 2022-09-02 10:35 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103446426.commit
0 2022-09-02 10:35 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103446426.commit.requested
0 2022-09-02 10:35 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103446426.inflight
2.6 K 2022-09-02 10:36 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103500190.commit
0 2022-09-02 10:35 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103500190.commit.requested
0 2022-09-02 10:35 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103500190.inflight
2.6 K 2022-09-02 10:36 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103507122.commit
0 2022-09-02 10:36 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103507122.commit.requested
0 2022-09-02 10:36 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103507122.inflight
2.6 K 2022-09-02 10:36 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103516798.commit
0 2022-09-02 10:36 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103516798.commit.requested
0 2022-09-02 10:36 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103516798.inflight
2.6 K 2022-09-02 10:36 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103526552.commit
0 2022-09-02 10:36 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103526552.commit.requested
0 2022-09-02 10:36 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103526552.inflight
2.6 K 2022-09-02 10:36 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103536698.commit
0 2022-09-02 10:36 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103536698.commit.requested
0 2022-09-02 10:36 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103536698.inflight
0 2022-09-02 10:36 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103546517.replacecommit.inflight
5.3 K 2022-09-02 10:36 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103546517.replacecommit.requested
2.6 K 2022-09-02 10:36 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103546726.commit
0 2022-09-02 10:36 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103546726.commit.requested
0 2022-09-02 10:36 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103546726.inflight
2.6 K 2022-09-02 10:36 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103556430.commit
0 2022-09-02 10:36 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103556430.commit.requested
0 2022-09-02 10:36 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103556430.inflight
2.6 K 2022-09-02 10:37 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103606316.commit
0 2022-09-02 10:36 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103606316.commit.requested
0 2022-09-02 10:36 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103606316.inflight
2.6 K 2022-09-02 10:37 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103618745.commit
0 2022-09-02 10:37 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103618745.commit.requested
0 2022-09-02 10:37 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103618745.inflight
2.6 K 2022-09-02 10:36 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103627453.clean
2.9 K 2022-09-02 10:36 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103627453.clean.inflight
2.9 K 2022-09-02 10:36 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103627453.clean.requested
0 2022-09-02 10:37 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103627564.commit.requested
0 2022-09-02 10:37 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/20220902103627564.inflight
0 2022-09-02 10:30 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/archived
1005 2022-09-02 10:30 /tmp/hudi/insert_cow_clustering_12_state_2/.hoodie/hoodie.properties
```
--
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.
To unsubscribe, e-mail: commits-unsubscribe@hudi.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org