Skip to content

Commit

Permalink
解决代码丢失问题
Browse files Browse the repository at this point in the history
  • Loading branch information
peacewong committed Dec 12, 2024
1 parent 9a7f80a commit a1d94e8
Showing 1 changed file with 0 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -175,7 +175,6 @@ abstract class EntranceServer extends Logging {
}

getEntranceContext.getOrCreateScheduler().submit(job)

val msg = LogUtils.generateInfo(
s"Job with jobId : ${jobRequest.getId} and execID : ${job.getId()} submitted "
)
Expand All @@ -190,10 +189,6 @@ abstract class EntranceServer extends Logging {
entranceJob.getLogListener.foreach(_.onLogUpdate(entranceJob, msg))
case _ =>
}
getEntranceContext
.getOrCreatePersistenceManager()
.createPersistenceEngine()
.updateIfNeeded(jobRequest)
LoggerUtils.removeJobIdMDC()
job
} { t =>
Expand Down

0 comments on commit a1d94e8

Please sign in to comment.