lincoln lee created FLINK-22604:
-----------------------------------
Summary: 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.12.3, 1.13.0
Reporter: lincoln lee
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)
