[ https://issues.apache.org/jira/browse/FLINK-22327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17324644#comment-17324644 ]
Dian Fu edited comment on FLINK-22327 at 4/19/21, 5:42 AM: ----------------------------------------------------------- Fixed in - master via 4f41e6dae85ce53d8dde432715b90789be719204 - release-1.12 via e64ed75a5f2dd89f8a23665a54ba3239bd362fdd - release-1.13 via a428ed4b6ab7a469ed25ab77471d93d8c3f6867d was (Author: dian.fu): Fixed in - master via 4f41e6dae85ce53d8dde432715b90789be719204 - release-1.12 via e64ed75a5f2dd89f8a23665a54ba3239bd362fdd > 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.12.3, 1.13.1 > > > 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)