Skip to content

Commit

Permalink
fix
Browse files Browse the repository at this point in the history
  • Loading branch information
924060929 committed Dec 20, 2024
1 parent c61f988 commit 15a3076
Showing 1 changed file with 1 addition and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -91,7 +91,6 @@ public class InsertOverwriteTableCommand extends Command implements ForwardWithS
private final Optional<LogicalPlan> cte;
private AtomicBoolean isCancelled = new AtomicBoolean(false);
private AtomicBoolean isRunning = new AtomicBoolean(false);
private Optional<CascadesContext> analyzeContext;

/**
* constructor
Expand All @@ -103,7 +102,6 @@ public InsertOverwriteTableCommand(LogicalPlan logicalQuery, Optional<String> la
this.logicalQuery = Optional.empty();
this.labelName = Objects.requireNonNull(labelName, "labelName should not be null");
this.cte = cte;
this.analyzeContext = Optional.empty();
}

public void setLabelName(Optional<String> labelName) {
Expand Down Expand Up @@ -133,7 +131,7 @@ public void run(ConnectContext ctx, StmtExecutor executor) throws Exception {
if (targetTableIf instanceof MTMV && !MTMVUtil.allowModifyMTMVData(ctx)) {
throw new AnalysisException("Not allowed to perform current operation on async materialized view");
}
this.analyzeContext = Optional.of(
Optional<CascadesContext> analyzeContext = Optional.of(
CascadesContext.initContext(ctx.getStatementContext(), originLogicalQuery, PhysicalProperties.ANY)
);
this.logicalQuery = Optional.of((LogicalPlan) InsertUtils.normalizePlan(
Expand Down

0 comments on commit 15a3076

Please sign in to comment.