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: 成彬彬 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
