This is an automated email from the ASF dual-hosted git repository.
danny0405 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git
The following commit(s) were added to refs/heads/master by this push:
new fa08eb2b512 [MINOR] Add logs in PartitionAwareClusteringPlanStrategy
(#10051)
fa08eb2b512 is described below
commit fa08eb2b51277e4aeb29f4664575acca6e432d44
Author: ksmou <[email protected]>
AuthorDate: Sun Nov 12 09:38:52 2023 +0800
[MINOR] Add logs in PartitionAwareClusteringPlanStrategy (#10051)
---
.../action/cluster/strategy/PartitionAwareClusteringPlanStrategy.java | 1 +
1 file changed, 1 insertion(+)
diff --git
a/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/cluster/strategy/PartitionAwareClusteringPlanStrategy.java
b/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/cluster/strategy/PartitionAwareClusteringPlanStrategy.java
index 309e6a4e480..c22c8b24eee 100644
---
a/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/cluster/strategy/PartitionAwareClusteringPlanStrategy.java
+++
b/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/cluster/strategy/PartitionAwareClusteringPlanStrategy.java
@@ -82,6 +82,7 @@ public abstract class
PartitionAwareClusteringPlanStrategy<T,I,K,O> extends Clus
// if fileSliceGroups's size reach the max group, stop loop
if (fileSliceGroups.size() >= writeConfig.getClusteringMaxNumGroups())
{
+ LOG.info("Having generated the maximum number of groups : " +
writeConfig.getClusteringMaxNumGroups());
break;
}
}