This is an automated email from the ASF dual-hosted git repository. aiceflower pushed a commit to branch release-1.0.2 in repository https://gitbox.apache.org/repos/asf/linkis.git
commit 13685dfcb7c6b9937e80f93b33adbf48bc2d88b6 Author: mindflow94 <[email protected]> AuthorDate: Mon Apr 11 14:23:21 2022 +0800 Release 1.0.2 (#1912) * Fix linkis-computation-client failed to submit jobs * Fix linkis-computation-client failed to submit jobs * Fix linkis-computation-client failed to submit jobs Co-authored-by: zhangyanzhao <[email protected]> --- .../linkis/computation/client/job/StorableLinkisJob.scala | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/linkis-computation-governance/linkis-client/linkis-computation-client/src/main/scala/com/webank/wedatasphere/linkis/computation/client/job/StorableLinkisJob.scala b/linkis-computation-governance/linkis-client/linkis-computation-client/src/main/scala/com/webank/wedatasphere/linkis/computation/client/job/StorableLinkisJob.scala index 0aaebc932c..96bd31c738 100644 --- a/linkis-computation-governance/linkis-client/linkis-computation-client/src/main/scala/com/webank/wedatasphere/linkis/computation/client/job/StorableLinkisJob.scala +++ b/linkis-computation-governance/linkis-client/linkis-computation-client/src/main/scala/com/webank/wedatasphere/linkis/computation/client/job/StorableLinkisJob.scala @@ -35,7 +35,7 @@ trait StorableLinkisJob extends AbstractLinkisJob { protected def getJobSubmitResult: JobSubmitResult - override protected def wrapperObj[T](obj: Object, errorMsg: String)(op: => T): T = wrapperId { + override protected def wrapperObj[T](obj: Object, errorMsg: String)(op: => T): T = { super.wrapperObj(obj, errorMsg)(op) } @@ -46,8 +46,8 @@ trait StorableLinkisJob extends AbstractLinkisJob { getJobMetrics.addClientGetJobInfoTime(System.currentTimeMillis - startTime) if(jobInfoResult.isCompleted) { getJobMetrics.setClientFinishedTime(System.currentTimeMillis) - info(s"Job-$getId is completed with status " + completedJobInfoResult.getJobStatus) completedJobInfoResult = jobInfoResult + info(s"Job-$getId is completed with status " + completedJobInfoResult.getJobStatus) getJobListeners.foreach(_.onJobFinished(this)) } else if(jobInfoResult.isRunning) getJobListeners.foreach(_.onJobRunning(this)) --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
