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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
