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 <zhangyanzhao@troila.com>
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 0aaebc9..96bd31c 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 @@
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 @@
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))
