Fix the problem that method call in circle.

wushengyeyouya · wushengyeyouya · commit 861fabc0b983 · 2022-04-01T14:10:10.000+08:00
diff --git a/streamis-jobmanager/streamis-job-launcher/streamis-job-launcher-linkis/src/main/scala/com/webank/wedatasphere/streamis/jobmanager/launcher/linkis/manager/SimpleFlinkJobManager.scala b/streamis-jobmanager/streamis-job-launcher/streamis-job-launcher-linkis/src/main/scala/com/webank/wedatasphere/streamis/jobmanager/launcher/linkis/manager/SimpleFlinkJobManager.scala
@@ -46,7 +46,7 @@ class SimpleFlinkJobManager extends FlinkJobManager {
     builder.build()
   }
 
-  override protected def createSubmittedOnceJob(id: String): OnceJob = SimpleOnceJob.build(id, getJobInfo(id).getUser)
+  override protected def createSubmittedOnceJob(id: String): OnceJob = SimpleOnceJob.build(id, onceJobIdToJobInfo.get(id).getUser)
 
   override protected def getStatus(id: String): String = getOnceJob(id) match {
     case simpleOnceJob: SimpleOnceJob =>

Original file line number	Diff line number	Diff line change
`@@ -46,7 +46,7 @@ class SimpleFlinkJobManager extends FlinkJobManager {`
`46`	`46`	`builder.build()`
`47`	`47`	`}`
`48`	`48`
`49`		`- override protected def createSubmittedOnceJob(id: String): OnceJob = SimpleOnceJob.build(id, getJobInfo(id).getUser)`
	`49`	`+ override protected def createSubmittedOnceJob(id: String): OnceJob = SimpleOnceJob.build(id, onceJobIdToJobInfo.get(id).getUser)`
`50`	`50`
`51`	`51`	`override protected def getStatus(id: String): String = getOnceJob(id) match {`
`52`	`52`	`case simpleOnceJob: SimpleOnceJob =>`