[jira] [Created] (FLINK-22604) NPE on bundle close when task failover after a failed task open

[Shang Yuanchun (Jira)]

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)