From b9f544b0a9d0eb74fed03f0b9257f617f5f6cbd9 Mon Sep 17 00:00:00 2001 From: Tomoyuki MORITA Date: Tue, 25 Jun 2024 21:02:54 -0700 Subject: [PATCH] Fix statement to store requested langType (#2777) Signed-off-by: Tomoyuki Morita --- .../sql/spark/execution/session/InteractiveSession.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/async-query-core/src/main/java/org/opensearch/sql/spark/execution/session/InteractiveSession.java b/async-query-core/src/main/java/org/opensearch/sql/spark/execution/session/InteractiveSession.java index 4a8d6a8f58..7c95f0eda5 100644 --- a/async-query-core/src/main/java/org/opensearch/sql/spark/execution/session/InteractiveSession.java +++ b/async-query-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)