From e2c426b26a90f5d7ffbc9e78f41f00ebdc57b68e Mon Sep 17 00:00:00 2001
From: "opensearch-trigger-bot[bot]"
 <98922864+opensearch-trigger-bot[bot]@users.noreply.github.com>
Date: Wed, 26 Jun 2024 20:16:00 -0700
Subject: [PATCH] Fix statement to store requested langType (#2777) (#2779)

(cherry picked from commit b9f544b0a9d0eb74fed03f0b9257f617f5f6cbd9)

Signed-off-by: Tomoyuki Morita <moritato@amazon.com>
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>
---
 .../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)