You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@linkis.apache.org by pe...@apache.org on 2023/05/29 13:34:28 UTC
[linkis] branch dev-1.4.0 updated: [Feature][linkis-computation-client] Provide a method which can get CreateEngineResult when submit a [once] job (#4583)
This is an automated email from the ASF dual-hosted git repository.
peacewong pushed a commit to branch dev-1.4.0
in repository https://gitbox.apache.org/repos/asf/linkis.git
The following commit(s) were added to refs/heads/dev-1.4.0 by this push:
new 427b2ff65 [Feature][linkis-computation-client] Provide a method which can get CreateEngineResult when submit a [once] job (#4583)
427b2ff65 is described below
commit 427b2ff659dfa12961dc48829bf52353aa3224bb
Author: rarexixi <ra...@gmail.com>
AuthorDate: Mon May 29 21:34:21 2023 +0800
[Feature][linkis-computation-client] Provide a method which can get CreateEngineResult when submit a [once] job (#4583)
---
.../linkis/computation/client/once/simple/SimpleOnceJob.scala | 7 +++++--
1 file changed, 5 insertions(+), 2 deletions(-)
diff --git a/linkis-computation-governance/linkis-client/linkis-computation-client/src/main/scala/org/apache/linkis/computation/client/once/simple/SimpleOnceJob.scala b/linkis-computation-governance/linkis-client/linkis-computation-client/src/main/scala/org/apache/linkis/computation/client/once/simple/SimpleOnceJob.scala
index baab361b5..492ae76b6 100644
--- a/linkis-computation-governance/linkis-client/linkis-computation-client/src/main/scala/org/apache/linkis/computation/client/once/simple/SimpleOnceJob.scala
+++ b/linkis-computation-governance/linkis-client/linkis-computation-client/src/main/scala/org/apache/linkis/computation/client/once/simple/SimpleOnceJob.scala
@@ -23,6 +23,7 @@ import org.apache.linkis.computation.client.LinkisJobMetrics
import org.apache.linkis.computation.client.job.AbstractSubmittableLinkisJob
import org.apache.linkis.computation.client.once.{LinkisManagerClient, OnceJob, SubmittableOnceJob}
import org.apache.linkis.computation.client.once.action.CreateEngineConnAction
+import org.apache.linkis.computation.client.once.result.CreateEngineConnResult
import org.apache.linkis.computation.client.operator.OnceJobOperator
import java.util.Locale
@@ -104,13 +105,15 @@ class SubmittableSimpleOnceJob(
with AbstractSubmittableLinkisJob {
private var ecmServiceInstance: ServiceInstance = _
+ private var createEngineConnResult: CreateEngineConnResult = _
def getECMServiceInstance: ServiceInstance = ecmServiceInstance
+ def getCreateEngineConnResult: CreateEngineConnResult = createEngineConnResult
override protected def doSubmit(): Unit = {
logger.info(s"Ready to create a engineConn: ${createEngineConnAction.getRequestPayload}.")
- val nodeInfo = linkisManagerClient.createEngineConn(createEngineConnAction)
- lastNodeInfo = nodeInfo.getNodeInfo
+ createEngineConnResult = linkisManagerClient.createEngineConn(createEngineConnAction)
+ lastNodeInfo = createEngineConnResult.getNodeInfo
serviceInstance = getServiceInstance(lastNodeInfo)
ticketId = getTicketId(lastNodeInfo)
ecmServiceInstance = getECMServiceInstance(lastNodeInfo)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@linkis.apache.org
For additional commands, e-mail: commits-help@linkis.apache.org