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)