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;
         }
       }

Reply via email to