(doris) branch master updated: [chore](mtmv)add plan log for UpdateMvByPartitionCommand (#40072)

[morrysnow]

This is an automated email from the ASF dual-hosted git repository.

morrysnow pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git


The following commit(s) were added to refs/heads/master by this push:
     new e24bc7f650a [chore](mtmv)add plan log for UpdateMvByPartitionCommand 
(#40072)
e24bc7f650a is described below

commit e24bc7f650ab7dbc2e974e68e42cdd5be38ac776
Author: zhangdong <493738...@qq.com>
AuthorDate: Thu Aug 29 14:47:30 2024 +0800

    [chore](mtmv)add plan log for UpdateMvByPartitionCommand (#40072)
    
    fe.conf set `sys_log_verbose_modules =
    org.apache.doris.nereids.trees.plans.commands.UpdateMvByPartitionCommand`
---
 .../nereids/trees/plans/commands/UpdateMvByPartitionCommand.java  | 8 ++++++++
 1 file changed, 8 insertions(+)

diff --git 
a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/UpdateMvByPartitionCommand.java
 
b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/UpdateMvByPartitionCommand.java
index ba1a054752b..de284bd8377 100644
--- 
a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/UpdateMvByPartitionCommand.java
+++ 
b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/UpdateMvByPartitionCommand.java
@@ -65,6 +65,8 @@ import com.google.common.collect.ImmutableSet;
 import com.google.common.collect.Lists;
 import com.google.common.collect.Range;
 import com.google.common.collect.Sets;
+import org.apache.logging.log4j.LogManager;
+import org.apache.logging.log4j.Logger;
 
 import java.util.ArrayList;
 import java.util.HashSet;
@@ -79,6 +81,8 @@ import java.util.stream.Collectors;
  * Update mv by partition
  */
 public class UpdateMvByPartitionCommand extends InsertOverwriteTableCommand {
+    private static final Logger LOG = 
LogManager.getLogger(UpdateMvByPartitionCommand.class);
+
     private UpdateMvByPartitionCommand(LogicalPlan logicalQuery) {
         super(logicalQuery, Optional.empty(), Optional.empty());
     }
@@ -104,6 +108,10 @@ public class UpdateMvByPartitionCommand extends 
InsertOverwriteTableCommand {
         }
         LogicalSink<? extends Plan> sink = 
UnboundTableSinkCreator.createUnboundTableSink(mv.getFullQualifiers(),
                 ImmutableList.of(), ImmutableList.of(), parts, plan);
+        if (LOG.isDebugEnabled()) {
+            LOG.debug("MTMVTask plan for mvName: {}, partitionNames: {}, plan: 
{}", mv.getName(), partitionNames,
+                    sink.treeString());
+        }
         return new UpdateMvByPartitionCommand(sink);
     }
 


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org