[jira] [Created] (FLINK-20250) NPE when invoking AsyncLookupJoinRunner#close method

["hailong wang (Jira)" <ji...@apache.org>]

hailong wang created FLINK-20250:
------------------------------------

             Summary: NPE when invoking AsyncLookupJoinRunner#close method
                 Key: FLINK-20250
                 URL: https://issues.apache.org/jira/browse/FLINK-20250
             Project: Flink
          Issue Type: Bug
          Components: Table SQL / Runtime
    Affects Versions: 1.12.0
            Reporter: hailong wang
             Fix For: 1.13.0


NPE when invoking AsyncLookupJoinRunner#close method,
{code:java}
java.lang.NullPointerException
    at org.apache.flink.table.runtime.operators.join.lookup.AsyncLookupJoinRunner.close(AsyncLookupJoinRunner.java:156)
    at org.apache.flink.api.common.functions.util.FunctionUtils.closeFunction(FunctionUtils.java:43)
    at org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.dispose(AbstractUdfStreamOperator.java:117)
    at org.apache.flink.streaming.runtime.tasks.StreamTask.disposeAllOperators(StreamTask.java:670)
    at org.apache.flink.streaming.runtime.tasks.StreamTask.cleanUpInvoke(StreamTask.java:581)
    at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:483)
    at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:709)
    at org.apache.flink.runtime.taskmanager.Task.run(Task.java:533)
    at java.lang.Thread.run(Thread.java:745)
{code}
This is because the job failed before it was initialized.

So We can add a null condition for allResultFutures object.

 



--
This message was sent by Atlassian Jira
(v8.3.4#803005)