[KYUUBI #5106][Flink] Improve logs for fatal errors

### _Why are the changes needed?_
As titled.

### _How was this patch tested?_
- [ ] Add some test cases that check the changes thoroughly including negative and positive cases if possible

- [ ] Add screenshots for manual tests if appropriate

- [x] [Run test](https://kyuubi.readthedocs.io/en/master/contributing/code/testing.html#running-tests) locally before make a pull request

Closes #5107 from link3280/engine_fatal_log.

Closes #5106

db45392d1 [Paul Lin] [KYUUBI #5106][Flink] Improve logs for fatal errors

Authored-by: Paul Lin <paullin3280@gmail.com>
Signed-off-by: Paul Lin <paullin3280@gmail.com>
This commit is contained in:
Paul Lin 2023-07-31 17:49:12 +08:00
parent 3162050566
commit 1d5a5c80c7

View File

@ -109,8 +109,8 @@ object FlinkSQLEngine extends Logging {
countDownLatch.await()
} catch {
case t: Throwable if currentEngine.isDefined =>
error("Fatal error occurs, thus stopping the engines", t)
currentEngine.foreach { engine =>
error(t)
engine.stop()
}
case t: Throwable =>