Skip to content

Commit 300c320

Browse files
committed
fix compile
Signed-off-by: Kai Huang <ahkcs@amazon.com>
1 parent 822d6ce commit 300c320

1 file changed

Lines changed: 2 additions & 8 deletions

File tree

core/src/main/java/org/opensearch/sql/executor/QueryService.java

Lines changed: 2 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,8 @@
55

66
package org.opensearch.sql.executor;
77

8+
import java.security.AccessController;
9+
import java.security.PrivilegedAction;
810
import java.util.List;
911
import java.util.Optional;
1012
import javax.annotation.Nullable;
@@ -135,14 +137,6 @@ public void executeWithCalcite(
135137
CalcitePlanContext.run(
136138
() -> {
137139
try {
138-
CalcitePlanContext context =
139-
CalcitePlanContext.create(
140-
buildFrameworkConfig(), SysLimit.fromSettings(settings), queryType);
141-
RelNode relNode = analyze(plan, context);
142-
relNode = mergeAdjacentFilters(relNode);
143-
RelNode optimized = optimize(relNode, context);
144-
RelNode calcitePlan = convertToCalcitePlan(optimized);
145-
executionEngine.execute(calcitePlan, context, listener);
146140
AccessController.doPrivileged(
147141
(PrivilegedAction<Void>)
148142
() -> {

0 commit comments

Comments
 (0)