Arvid Heise created FLINK-38486:
-----------------------------------
Summary: Harden shutdown of DefaultExpressionEvaluator
Key: FLINK-38486
URL: https://issues.apache.org/jira/browse/FLINK-38486
Project: Flink
Issue Type: Bug
Components: Table SQL / Runtime
Affects Versions: 2.1.0
Reporter: Arvid Heise
Assignee: Arvid Heise
While closing DefaultExpressionEvaluator before opening, the following error
may occur.
{noformat}
org.apache.flink.table.api.TableException: Expression evaluator for '=($0,
$1)' could not be closed. at
org.apache.flink.table.runtime.functions.DefaultExpressionEvaluator.close(DefaultExpressionEvaluator.java:82)
at
org.apache.flink.table.runtime.functions.scalar.ArrayPositionFunction.close(ArrayPositionFunction.java:89)
at StreamExecCalc$1510.close(Unknown Source) at
org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.close(StreamOperatorWrapper.java:163)
at
org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.closeAllOperators(RegularOperatorChain.java:139)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.closeAllOperators(StreamTask.java:1160)
at org.apache.flink.util.IOUtils.closeAll(IOUtils.java:255) at
org.apache.flink.core.fs.AutoCloseableRegistry.doClose(AutoCloseableRegistry.java:83)
at
org.apache.flink.util.AbstractAutoCloseableRegistry.close(AbstractAutoCloseableRegistry.java:127)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.cleanUp(StreamTask.java:1064)
at
org.apache.flink.runtime.taskmanager.Task.lambda$restoreAndInvoke$3(Task.java:1052)
at
org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:1067)
at
org.apache.flink.runtime.taskmanager.Task.lambda$restoreAndInvoke$4(Task.java:1052)
at org.apache.flink.util.IOUtils.closeAll(IOUtils.java:255) at
org.apache.flink.core.fs.AutoCloseableRegistry.doClose(AutoCloseableRegistry.java:83)
at
org.apache.flink.util.AbstractAutoCloseableRegistry.close(AbstractAutoCloseableRegistry.java:127)
at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:878) at
org.apache.flink.runtime.taskmanager.Task.run(Task.java:655) at
java.base/java.lang.Thread.run(Thread.java:829)Caused by:
java.lang.NullPointerException at
org.apache.flink.table.runtime.functions.DefaultExpressionEvaluator.close(DefaultExpressionEvaluator.java:...{noformat}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
