Fix statement to store requested langType (#2777)

Signed-off-by: Tomoyuki Morita <[email protected]>
opensearch-project · Jun 26, 2024 · b9f544b · b9f544b
1 parent b2403ca
commit b9f544b
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/...ery-core/src/main/java/org/opensearch/sql/spark/execution/session/InteractiveSession.java b/...ery-core/src/main/java/org/opensearch/sql/spark/execution/session/InteractiveSession.java
@@ -25,7 +25,6 @@
 import org.opensearch.sql.spark.execution.statement.StatementId;
 import org.opensearch.sql.spark.execution.statestore.SessionStorageService;
 import org.opensearch.sql.spark.execution.statestore.StatementStorageService;
-import org.opensearch.sql.spark.rest.model.LangType;
 import org.opensearch.sql.spark.utils.TimeProvider;
 
 /**
@@ -111,7 +110,7 @@ public StatementId submit(
                 .jobId(sessionModel.getJobId())
                 .statementStorageService(statementStorageService)
                 .statementId(statementId)
-                .langType(LangType.SQL)
+                .langType(request.getLangType())
                 .datasourceName(sessionModel.getDatasourceName())
                 .query(request.getQuery())
                 .queryId(qid)