[Bug] BaseRichOutputFormat 抛出NoRestartException 可能会导致任务无法正常停止

[zhourui999]

Search before asking

• I had searched in the issues and found no similar issues.

What happened

timerWriteException 这个变量的赋值只会在定时任务失败后，如果是preCommit调用则会导致抛出的NoRestartException被吃掉

What you expected to happen

任务停止

How to reproduce

关闭定时提交的任务initTimingSubmitTask()

Anything else

No response

Version

master

Are you willing to submit PR?

• Yes I am willing to submit a PR!

Code of Conduct

• I agree to follow this project's Code of Conduct

[zoudaokoulife]

这个地方确实是一个bug;

这个地方不应该只是打印日志；

[zoudaokoulife]

@zhourui999 你要修复下这个bug吗？

[zhourui999]

建议加上 checkTimerWriteException(); 要不然脏数据产生有时也不能立马停止。目前是产生一个脏数据后，需要后续继续有数据过来才能停止程序