Details
-
Improvement
-
Status: Closed
-
Minor
-
Resolution: Fixed
-
v4.0.0
-
None
-
None
Description
In the execute method in JobWorker, after the error is thrown, the error details are not printed, but called the method for handling the error. When the method for handling the error is executed, other errors are generated, resulting in the real error information being hidden.
private def execute(): Unit = { pool.execute(new Runnable { override def run(): Unit = { try { logInfo("Start running job.") application.execute(args) eventLoop.post(JobSucceeded()) } catch { case exception: NoRetryException => eventLoop.post(UnknownThrowable(exception)) case throwable: Throwable => eventLoop.post(ResourceLack(throwable)) } } }) }