File tree Expand file tree Collapse file tree
core/src/main/java/org/opensearch/sql/calcite Expand file tree Collapse file tree Original file line number Diff line number Diff line change 99import static org .apache .calcite .sql .SqlKind .AS ;
1010import static org .opensearch .sql .ast .expression .SpanUnit .NONE ;
1111import static org .opensearch .sql .ast .expression .SpanUnit .UNKNOWN ;
12- import static org .opensearch .sql .calcite .CalcitePlanContext .create ;
1312import static org .opensearch .sql .calcite .utils .OpenSearchTypeFactory .TYPE_FACTORY ;
1413
1514import java .math .BigDecimal ;
@@ -323,8 +322,7 @@ public CalcitePlanContext prepareLambdaContext(
323322 String functionName ,
324323 @ Nullable RelDataType defaultTypeForReduceAcc ) {
325324 try {
326- CalcitePlanContext lambdaContext =
327- create (context .config , context .querySizeLimit , context .queryType );
325+ CalcitePlanContext lambdaContext = context .clone ();
328326 List <RelDataType > candidateType = new ArrayList <>();
329327 candidateType .add (
330328 ((ArraySqlType ) previousArgument .get (0 ).getType ())
You can’t perform that action at this time.
0 commit comments