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 2022/04/11 06:23:28 UTC
[incubator-linkis] branch release-1.0.2 updated: Release 1.0.2 (#1912)
This is an automated email from the ASF dual-hosted git repository.
peacewong pushed a commit to branch release-1.0.2
in repository https://gitbox.apache.org/repos/asf/incubator-linkis.git
The following commit(s) were added to refs/heads/release-1.0.2 by this push:
new d753b47c5 Release 1.0.2 (#1912)
d753b47c5 is described below
commit d753b47c54f83079b19826829a706a2dc624bcc5
Author: mindflow94 <35...@users.noreply.github.com>
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 <zh...@troila.com>
---
.../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 0aaebc932..96bd31c73 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: commits-unsubscribe@linkis.apache.org
For additional commands, e-mail: commits-help@linkis.apache.org