[incubator-linkis] branch dev-1.3.1 updated: [linkis-engineplugin-presto] Modification of scala file floating red (#3213)

[ca...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

casion pushed a commit to branch dev-1.3.1
in repository https://gitbox.apache.org/repos/asf/incubator-linkis.git


The following commit(s) were added to refs/heads/dev-1.3.1 by this push:
     new 113a4056f [linkis-engineplugin-presto] Modification of scala file floating red (#3213)
113a4056f is described below

commit 113a4056fdd3f2ac73b41da67a6c9fd9bdfc5011
Author: 成彬彬 <10...@users.noreply.github.com>
AuthorDate: Sat Sep 3 13:26:45 2022 +0800

    [linkis-engineplugin-presto] Modification of scala file floating red (#3213)
---
 .../engineplugin/presto/executer/PrestoEngineConnExecutor.scala  | 9 +++++----
 1 file changed, 5 insertions(+), 4 deletions(-)

diff --git a/linkis-engineconn-plugins/presto/src/main/scala/org/apache/linkis/engineplugin/presto/executer/PrestoEngineConnExecutor.scala b/linkis-engineconn-plugins/presto/src/main/scala/org/apache/linkis/engineplugin/presto/executer/PrestoEngineConnExecutor.scala
index 27c8e83ce..59b0a1b65 100644
--- a/linkis-engineconn-plugins/presto/src/main/scala/org/apache/linkis/engineplugin/presto/executer/PrestoEngineConnExecutor.scala
+++ b/linkis-engineconn-plugins/presto/src/main/scala/org/apache/linkis/engineplugin/presto/executer/PrestoEngineConnExecutor.scala
@@ -53,7 +53,7 @@ import org.apache.linkis.storage.resultset.ResultSetFactory
 import org.apache.linkis.storage.resultset.table.{TableMetaData, TableRecord}
 
 import org.apache.commons.io.IOUtils
-import org.apache.commons.lang.exception.ExceptionUtils
+import org.apache.commons.lang3.exception.ExceptionUtils
 
 import org.springframework.util.CollectionUtils
 
@@ -196,7 +196,7 @@ class PrestoEngineConnExecutor(override val outputPrintLimit: Int, val id: Int)
       cacheMap: util.Map[String, String]
   ): ClientSession = {
     val configMap = new util.HashMap[String, String]()
-    // 运行时指定的参数优先级大于管理台配置优先级
+    // The parameter priority specified at runtime is higher than the configuration priority of the management console
     if (!CollectionUtils.isEmpty(cacheMap)) configMap.putAll(cacheMap)
     taskParams.asScala.foreach {
       case (key: String, value: Object) if value != null =>
@@ -331,7 +331,7 @@ class PrestoEngineConnExecutor(override val outputPrintLimit: Int, val id: Int)
           cause = error.getFailureInfo.toException
         }
         engineExecutorContext.appendStdout(
-          LogUtils.generateERROR(ExceptionUtils.getFullStackTrace(cause))
+          LogUtils.generateERROR(ExceptionUtils.getStackTrace(cause))
         )
         ErrorExecuteResponse(ExceptionUtils.getMessage(cause), cause)
       } else null
@@ -364,8 +364,9 @@ class PrestoEngineConnExecutor(override val outputPrintLimit: Int, val id: Int)
 
     var builder: ClientSession.Builder = ClientSession.builder(newSession)
 
-    if (statement.getStartedTransactionId != null)
+    if (statement.getStartedTransactionId != null) {
       builder = builder.withTransactionId(statement.getStartedTransactionId)
+    }
 
     // update session properties if present
     if (


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@linkis.apache.org
For additional commands, e-mail: commits-help@linkis.apache.org