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/06/24 03:17:44 UTC
[incubator-linkis] branch dev-1.2.0 updated: FIX [Bug] Linkis-computation-client failed to submit jobs (#2333)
This is an automated email from the ASF dual-hosted git repository.
peacewong pushed a commit to branch dev-1.2.0
in repository https://gitbox.apache.org/repos/asf/incubator-linkis.git
The following commit(s) were added to refs/heads/dev-1.2.0 by this push:
new 3c95ac409 FIX [Bug] Linkis-computation-client failed to submit jobs (#2333)
3c95ac409 is described below
commit 3c95ac4093fb4590032171772ee2899ad46bf7e1
Author: mindflow94 <35...@users.noreply.github.com>
AuthorDate: Fri Jun 24 11:17:38 2022 +0800
FIX [Bug] Linkis-computation-client failed to submit jobs (#2333)
Co-authored-by: zhangyanzhao <zh...@troila.com>
---
.../org/apache/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/org/apache/linkis/computation/client/job/StorableLinkisJob.scala b/linkis-computation-governance/linkis-client/linkis-computation-client/src/main/scala/org/apache/linkis/computation/client/job/StorableLinkisJob.scala
index 3894a1a40..49499689d 100644
--- a/linkis-computation-governance/linkis-client/linkis-computation-client/src/main/scala/org/apache/linkis/computation/client/job/StorableLinkisJob.scala
+++ b/linkis-computation-governance/linkis-client/linkis-computation-client/src/main/scala/org/apache/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