From 4767136c1fd1c20cd9ebd40008bced308dd6196b Mon Sep 17 00:00:00 2001 From: zhangdong <493738387@qq.com> Date: Wed, 10 Jul 2024 14:31:13 +0800 Subject: [PATCH 1/2] 1 --- .../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 517909f5e1f128..c8036938b1868e 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.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 void run() throws JobException { private void exec(ConnectContext ctx, Set refreshPartitionNames, Map tableWithPartKey) throws Exception { + Objects.requireNonNull(ctx); + 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 From 2e9102f1db5ca2194de6bfa43cd68e8e64a9683b Mon Sep 17 00:00:00 2001 From: zhangdong <493738387@qq.com> Date: Wed, 10 Jul 2024 20:30:37 +0800 Subject: [PATCH 2/2] 1 --- .../java/org/apache/doris/job/extensions/mtmv/MTMVTask.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 c8036938b1868e..b50d755951f9df 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 @@ -223,7 +223,7 @@ public void run() throws JobException { private void exec(ConnectContext ctx, Set refreshPartitionNames, Map tableWithPartKey) throws Exception { - Objects.requireNonNull(ctx); + Objects.requireNonNull(ctx, "ctx should not be null"); StatementContext statementContext = new StatementContext(); ctx.setStatementContext(statementContext); TUniqueId queryId = generateQueryId();