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 0fa2a56ce linkis-accessible-executor - fix bug in
DefaultOperateService (#4817)
0fa2a56ce is described below
commit 0fa2a56ce5f67ea3f5c49c5aee05787d756f0f1a
Author: Alexyang <[email protected]>
AuthorDate: Tue Jul 25 18:22:47 2023 +0800
linkis-accessible-executor - fix bug in DefaultOperateService (#4817)
---
.../acessible/executor/service/DefaultOperateService.scala | 8 +++++---
1 file changed, 5 insertions(+), 3 deletions(-)
diff --git
a/linkis-computation-governance/linkis-engineconn/linkis-engineconn-executor/accessible-executor/src/main/scala/org/apache/linkis/engineconn/acessible/executor/service/DefaultOperateService.scala
b/linkis-computation-governance/linkis-engineconn/linkis-engineconn-executor/accessible-executor/src/main/scala/org/apache/linkis/engineconn/acessible/executor/service/DefaultOperateService.scala
index f82c5e944..20399711b 100644
---
a/linkis-computation-governance/linkis-engineconn/linkis-engineconn-executor/accessible-executor/src/main/scala/org/apache/linkis/engineconn/acessible/executor/service/DefaultOperateService.scala
+++
b/linkis-computation-governance/linkis-engineconn/linkis-engineconn-executor/accessible-executor/src/main/scala/org/apache/linkis/engineconn/acessible/executor/service/DefaultOperateService.scala
@@ -42,9 +42,11 @@ class DefaultOperateService extends OperateService with
Logging {
engineOperateRequest: EngineOperateRequest
): EngineOperateResponse = {
var response: EngineOperateResponse = null
-
- val parameters =
-
engineOperateRequest.getParameters.asScala.toMap.asInstanceOf[util.Map[String,
Object]]
+ val parameters = {
+ val map = new util.HashMap[String, Object]()
+ engineOperateRequest.getParameters.asScala.foreach(entry =>
map.put(entry._1, entry._2))
+ map
+ }
val operator =
Utils.tryCatch(OperatorFactory.apply().getOperatorRequest(parameters)) { t =>
logger.error(s"Get operator failed, parameters is
${engineOperateRequest.getParameters}.", t)
response = new EngineOperateResponse(
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
