[
https://issues.apache.org/jira/browse/FLINK-38486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Khachatryan reopened FLINK-38486:
---------------------------------------
> 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
> Priority: Major
> Labels: pull-request-available
> Fix For: 2.2.0
>
>
> 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)
