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)