[ https://issues.apache.org/jira/browse/FLINK-22327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Dian Fu updated FLINK-22327: ---------------------------- Fix Version/s: (was: 1.13.1) (was: 1.14.0) 1.13.0 > NPE exception happens if it throws exception in finishBundle during job > shutdown > -------------------------------------------------------------------------------- > > Key: FLINK-22327 > URL: https://issues.apache.org/jira/browse/FLINK-22327 > Project: Flink > Issue Type: Bug > Components: API / Python > Reporter: Dian Fu > Assignee: Dian Fu > Priority: Major > Labels: pull-request-available > Fix For: 1.13.0, 1.12.3 > > > Currently, if it throws exceptions in finishBundle during job shutdown, NPE > exception may happen if time-based finish bundle is scheduled. It caused the > actual exception isn't propagate. This makes users very difficult to trouble > shot the problem. > See > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/PyFlink-called-already-closed-and-NullPointerException-td42997.html > for more details. -- This message was sent by Atlassian Jira (v8.3.4#803005)