Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/4374
@RebornHuan although this change looks to be correct and makes good use of
the newer API, there is a trade-off between deleting a line of code called
during an error condition and the risk of such small refactorings. I don't
think we have a demonstrated benefit to making this change.---
