This is an automated email from the ASF dual-hosted git repository.
peacewong pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/linkis.git
The following commit(s) were added to refs/heads/master by this push:
new b6af5f0c3 [WIP]fix issues #4972 #4973 (#4972)
b6af5f0c3 is described below
commit b6af5f0c3eac21ba73d4a0bb08c16a6fe6b460eb
Author: ZHANG HUA JIN <[email protected]>
AuthorDate: Sun Nov 19 21:42:23 2023 +0800
[WIP]fix issues #4972 #4973 (#4972)
---
.../src/main/scala/org/apache/linkis/server/ticket/RedisClient.scala | 2 +-
.../engineconn/computation/executor/execute/ComputationExecutor.scala | 1 +
2 files changed, 2 insertions(+), 1 deletion(-)
diff --git
a/linkis-commons/linkis-module/src/main/scala/org/apache/linkis/server/ticket/RedisClient.scala
b/linkis-commons/linkis-module/src/main/scala/org/apache/linkis/server/ticket/RedisClient.scala
index 8f09139e0..73699f38e 100644
---
a/linkis-commons/linkis-module/src/main/scala/org/apache/linkis/server/ticket/RedisClient.scala
+++
b/linkis-commons/linkis-module/src/main/scala/org/apache/linkis/server/ticket/RedisClient.scala
@@ -70,7 +70,7 @@ object RedisClient {
SessionHAConfiguration.RedisHost,
SessionHAConfiguration.RedisPort,
redisTimeout,
- SessionHAConfiguration.RedisSentinalServer
+ SessionHAConfiguration.RedisPassword
)
}
diff --git
a/linkis-computation-governance/linkis-engineconn/linkis-computation-engineconn/src/main/scala/org/apache/linkis/engineconn/computation/executor/execute/ComputationExecutor.scala
b/linkis-computation-governance/linkis-engineconn/linkis-computation-engineconn/src/main/scala/org/apache/linkis/engineconn/computation/executor/execute/ComputationExecutor.scala
index 940973be6..ea80b625b 100644
---
a/linkis-computation-governance/linkis-engineconn/linkis-computation-engineconn/src/main/scala/org/apache/linkis/engineconn/computation/executor/execute/ComputationExecutor.scala
+++
b/linkis-computation-governance/linkis-engineconn/linkis-computation-engineconn/src/main/scala/org/apache/linkis/engineconn/computation/executor/execute/ComputationExecutor.scala
@@ -271,6 +271,7 @@ abstract class ComputationExecutor(val outputPrintLimit:
Int = 1000)
TaskResponseErrorEvent(engineConnTask.getTaskId,
errorExecuteResponse.message)
)
transformTaskStatus(engineConnTask, ExecutionNodeStatus.Failed)
+ case _ => logger.warn(s"task get response is $executeResponse")
}
executeResponse
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
