From 91e210d6fd8b0fc8d4982d38e535520926fd5431 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E2=80=9Cv=5Fkkhuang=E2=80=9D?= <“420895376@qq.com”>
Date: Mon, 23 Sep 2024 10:25:37 +0800
Subject: [PATCH] Fix engine  cannot find symbol

---
 .../executor/ElasticSearchEngineConnExecutor.java           | 6 +++---
 .../presto/executor/PrestoEngineConnExecutor.java           | 4 ++--
 2 files changed, 5 insertions(+), 5 deletions(-)

diff --git a/linkis-engineconn-plugins/elasticsearch/src/main/java/org/apache/linkis/engineplugin/elasticsearch/executor/ElasticSearchEngineConnExecutor.java b/linkis-engineconn-plugins/elasticsearch/src/main/java/org/apache/linkis/engineplugin/elasticsearch/executor/ElasticSearchEngineConnExecutor.java
index 4109507f5d..fcb4a641c9 100644
--- a/linkis-engineconn-plugins/elasticsearch/src/main/java/org/apache/linkis/engineplugin/elasticsearch/executor/ElasticSearchEngineConnExecutor.java
+++ b/linkis-engineconn-plugins/elasticsearch/src/main/java/org/apache/linkis/engineplugin/elasticsearch/executor/ElasticSearchEngineConnExecutor.java
@@ -43,7 +43,7 @@
 import org.apache.linkis.scheduler.executer.ErrorExecuteResponse;
 import org.apache.linkis.scheduler.executer.ExecuteResponse;
 import org.apache.linkis.storage.LineRecord;
-import org.apache.linkis.storage.resultset.ResultSetFactory;
+import org.apache.linkis.storage.resultset.ResultSetFactory$;
 import org.apache.linkis.storage.resultset.table.TableMetaData;
 
 import org.apache.commons.collections.MapUtils;
@@ -134,7 +134,7 @@ public ExecuteResponse executeLine(EngineExecutionContext engineExecutorContext,
             (ElasticSearchTableResponse) elasticSearchResponse;
         TableMetaData metaData = new TableMetaData(tableResponse.columns());
         ResultSetWriter<? extends MetaData, ? extends Record> resultSetWriter =
-            engineExecutorContext.createResultSetWriter(ResultSetFactory.TABLE_TYPE());
+            engineExecutorContext.createResultSetWriter(ResultSetFactory$.MODULE$.TABLE_TYPE());
         resultSetWriter.addMetaData(metaData);
         Arrays.asList(tableResponse.records())
             .forEach(
@@ -152,7 +152,7 @@ record -> {
       } else if (elasticSearchResponse instanceof ElasticSearchJsonResponse) {
         ElasticSearchJsonResponse jsonResponse = (ElasticSearchJsonResponse) elasticSearchResponse;
         ResultSetWriter<? extends MetaData, ? extends Record> resultSetWriter =
-            engineExecutorContext.createResultSetWriter(ResultSetFactory.TEXT_TYPE());
+            engineExecutorContext.createResultSetWriter(ResultSetFactory$.MODULE$.TABLE_TYPE());
         resultSetWriter.addMetaData(null);
         Arrays.stream(jsonResponse.value().split("\\n"))
             .forEach(
diff --git a/linkis-engineconn-plugins/presto/src/main/java/org/apache/linkis/engineplugin/presto/executor/PrestoEngineConnExecutor.java b/linkis-engineconn-plugins/presto/src/main/java/org/apache/linkis/engineplugin/presto/executor/PrestoEngineConnExecutor.java
index 460de48305..1bc16ee601 100644
--- a/linkis-engineconn-plugins/presto/src/main/java/org/apache/linkis/engineplugin/presto/executor/PrestoEngineConnExecutor.java
+++ b/linkis-engineconn-plugins/presto/src/main/java/org/apache/linkis/engineplugin/presto/executor/PrestoEngineConnExecutor.java
@@ -48,7 +48,7 @@
 import org.apache.linkis.scheduler.executer.SuccessExecuteResponse;
 import org.apache.linkis.storage.domain.Column;
 import org.apache.linkis.storage.domain.DataType;
-import org.apache.linkis.storage.resultset.ResultSetFactory;
+import org.apache.linkis.storage.resultset.ResultSetFactory$;
 import org.apache.linkis.storage.resultset.table.TableMetaData;
 import org.apache.linkis.storage.resultset.table.TableRecord;
 
@@ -325,7 +325,7 @@ private void queryOutput(
     int columnCount = 0;
     int rows = 0;
     ResultSetWriter resultSetWriter =
-        engineExecutorContext.createResultSetWriter(ResultSetFactory.TABLE_TYPE());
+        engineExecutorContext.createResultSetWriter(ResultSetFactory$.MODULE$.TABLE_TYPE());
     try {
       QueryStatusInfo results = null;
       if (statement.isRunning()) {