From 9dab55ad80678a8b7da832f0f269a8bb06dba103 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 11:28:40 +0800 Subject: [PATCH] fix cannot find symbol --- .../engineplugin/doris/executor/DorisEngineConnExecutor.java | 5 ++--- .../engineplugin/repl/executor/ReplEngineConnExecutor.java | 4 ++-- 2 files changed, 4 insertions(+), 5 deletions(-) diff --git a/linkis-engineconn-plugins/doris/src/main/java/org/apache/linkis/engineplugin/doris/executor/DorisEngineConnExecutor.java b/linkis-engineconn-plugins/doris/src/main/java/org/apache/linkis/engineplugin/doris/executor/DorisEngineConnExecutor.java index 9eb60566d6..ba64ee171b 100644 --- a/linkis-engineconn-plugins/doris/src/main/java/org/apache/linkis/engineplugin/doris/executor/DorisEngineConnExecutor.java +++ b/linkis-engineconn-plugins/doris/src/main/java/org/apache/linkis/engineplugin/doris/executor/DorisEngineConnExecutor.java @@ -49,8 +49,6 @@ import org.apache.linkis.scheduler.executer.SuccessExecuteResponse; import org.apache.linkis.storage.LineMetaData; import org.apache.linkis.storage.LineRecord; -import org.apache.linkis.storage.resultset.ResultSetFactory; - import org.apache.commons.codec.binary.Base64; import org.apache.commons.collections4.MapUtils; import org.apache.commons.io.FilenameUtils; @@ -66,6 +64,7 @@ import org.apache.http.impl.client.HttpClients; import org.apache.http.util.EntityUtils; +import org.apache.linkis.storage.resultset.ResultSetFactory$; import org.springframework.util.CollectionUtils; import java.io.File; @@ -249,7 +248,7 @@ public ExecuteResponse executeLine(EngineExecutionContext engineExecutorContext, engineExecutorContext.appendStdout(resultMessageStringBuilder.toString()); ResultSetWriter resultSetWriter = - engineExecutorContext.createResultSetWriter(ResultSetFactory.TEXT_TYPE()); + engineExecutorContext.createResultSetWriter(ResultSetFactory$.MODULE$.TEXT_TYPE()); try { resultSetWriter.addMetaData(new LineMetaData(null)); resultSetWriter.addRecord(new LineRecord(resultMessageStringBuilder.toString())); diff --git a/linkis-engineconn-plugins/repl/src/main/java/org/apache/linkis/engineplugin/repl/executor/ReplEngineConnExecutor.java b/linkis-engineconn-plugins/repl/src/main/java/org/apache/linkis/engineplugin/repl/executor/ReplEngineConnExecutor.java index 9aa8aa45e7..f6a50c2527 100644 --- a/linkis-engineconn-plugins/repl/src/main/java/org/apache/linkis/engineplugin/repl/executor/ReplEngineConnExecutor.java +++ b/linkis-engineconn-plugins/repl/src/main/java/org/apache/linkis/engineplugin/repl/executor/ReplEngineConnExecutor.java @@ -44,13 +44,13 @@ import org.apache.linkis.scheduler.executer.SuccessExecuteResponse; import org.apache.linkis.storage.LineMetaData; import org.apache.linkis.storage.LineRecord; -import org.apache.linkis.storage.resultset.ResultSetFactory; import org.apache.commons.collections4.MapUtils; import org.apache.commons.io.IOUtils; import org.apache.commons.lang3.StringUtils; import org.apache.commons.lang3.exception.ExceptionUtils; +import org.apache.linkis.storage.resultset.ResultSetFactory$; import org.springframework.util.CollectionUtils; import java.io.ByteArrayOutputStream; @@ -161,7 +161,7 @@ public ExecuteResponse executeLine(EngineExecutionContext engineExecutorContext, System.setOut(oldStream); engineExecutorContext.appendStdout(message); ResultSetWriter resultSetWriter = - engineExecutorContext.createResultSetWriter(ResultSetFactory.TEXT_TYPE()); + engineExecutorContext.createResultSetWriter(ResultSetFactory$.MODULE$.TEXT_TYPE()); try { resultSetWriter.addMetaData(new LineMetaData(null)); resultSetWriter.addRecord(new LineRecord(message));