[
https://issues.apache.org/jira/browse/FLINK-22604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee reassigned FLINK-22604:
------------------------------------
Assignee: lincoln lee
> NPE on bundle close when task failover after a failed task open
> ---------------------------------------------------------------
>
> Key: FLINK-22604
> URL: https://issues.apache.org/jira/browse/FLINK-22604
> Project: Flink
> Issue Type: Bug
> Components: Table SQL / Runtime
> Affects Versions: 1.13.0, 1.12.3
> Reporter: lincoln lee
> Assignee: lincoln lee
> Priority: Minor
> Labels: pull-request-available
> Fix For: 1.14.0
>
>
> We observed a NullPointerException when job failover after a failed task
> open(e.g., stuck on initializing), this should be avoid.
> A simulated case will reproduce the exception:
> {code}
> @Test
> def testCloseWithoutOpen(): Unit = {
> val (testHarness, outputType) = createAggregationWithDistinct // see
> detail in the patch
> testHarness.setup(new RowDataSerializer(outputType: _*))
> // simulate a failover after a failed task open(e.g., stuck on
> initializing)
> // expect no exception happens
> testHarness.close()
> }
> {code}
> exception:
> {code}
> java.lang.NullPointerExceptionjava.lang.NullPointerException at
> org.apache.flink.table.runtime.operators.bundle.AbstractMapBundleOperator.finishBundle(AbstractMapBundleOperator.java:134)
> at
> org.apache.flink.table.runtime.operators.bundle.AbstractMapBundleOperator.close(AbstractMapBundleOperator.java:156)
> at
> org.apache.flink.streaming.util.AbstractStreamOperatorTestHarness.close(AbstractStreamOperatorTestHarness.java:691)
> {code}
>
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
