Fix statement to store requested langType (#2777) (#2779)

(cherry picked from commit b9f544b) Signed-off-by: Tomoyuki Morita <[email protected]> Signed-off-by: github-actions[bot] <github-actions[bot]@users.noreply.github.com> Co-authored-by: github-actions[bot] <github-actions[bot]@users.noreply.github.com>
opensearch-project · Jun 27, 2024 · e2c426b · e2c426b
1 parent 93588c8
commit e2c426b
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)