From f1d22a9610b6eb132e4c9e79c6bb798281ce29af Mon Sep 17 00:00:00 2001 From: zhangdong <493738387@qq.com> Date: Tue, 16 Jul 2024 11:08:18 +0800 Subject: [PATCH] [fix](mtmv) fix mtmv task nereids cost too much time (#37589) (#37819) pick: https://github.com/apache/doris/pull/37589 --- .../java/org/apache/doris/job/extensions/mtmv/MTMVTask.java | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/fe/fe-core/src/main/java/org/apache/doris/job/extensions/mtmv/MTMVTask.java b/fe/fe-core/src/main/java/org/apache/doris/job/extensions/mtmv/MTMVTask.java index 517909f5e1..b50d755951 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/job/extensions/mtmv/MTMVTask.java +++ b/fe/fe-core/src/main/java/org/apache/doris/job/extensions/mtmv/MTMVTask.java @@ -41,6 +41,7 @@ import org.apache.doris.mtmv.MTMVRefreshEnum.RefreshMethod; import org.apache.doris.mtmv.MTMVRefreshPartitionSnapshot; import org.apache.doris.mtmv.MTMVRelation; import org.apache.doris.mtmv.MTMVUtil; +import org.apache.doris.nereids.StatementContext; import org.apache.doris.nereids.glue.LogicalPlanAdapter; import org.apache.doris.nereids.trees.plans.commands.UpdateMvByPartitionCommand; import org.apache.doris.nereids.trees.plans.commands.info.TableNameInfo; @@ -222,6 +223,9 @@ public class MTMVTask extends AbstractTask { private void exec(ConnectContext ctx, Set refreshPartitionNames, Map tableWithPartKey) throws Exception { + Objects.requireNonNull(ctx, "ctx should not be null"); + StatementContext statementContext = new StatementContext(); + ctx.setStatementContext(statementContext); TUniqueId queryId = generateQueryId(); lastQueryId = DebugUtil.printId(queryId); // if SELF_MANAGE mv, only have default partition, will not have partitionItem, so we give empty set