Dian Fu created FLINK-21944:
-------------------------------
Summary: AbstractArrowPythonAggregateFunctionOperator.dispose
should consider whether arrowSerializer is null
Key: FLINK-21944
URL: https://issues.apache.org/jira/browse/FLINK-21944
Project: Flink
Issue Type: Bug
Components: API / Python
Reporter: Dian Fu
Fix For: 1.13.0, 1.12.3
{code}
java.lang.RuntimeException: Failed to create stage bundle
factory!java.lang.RuntimeException: Failed to create stage bundle factory! at
org.apache.flink.streaming.api.runners.python.beam.BeamPythonFunctionRunner.createStageBundleFactory(BeamPythonFunctionRunner.java:415)
~[?:?] at
org.apache.flink.streaming.api.runners.python.beam.BeamPythonFunctionRunner.open(BeamPythonFunctionRunner.java:259)
~[?:?] at
org.apache.flink.streaming.api.operators.python.AbstractPythonFunctionOperator.open(AbstractPythonFunctionOperator.java:113)
~[?:?] at
org.apache.flink.table.runtime.operators.python.AbstractStatelessFunctionOperator.open(AbstractStatelessFunctionOperator.java:116)
~[?:?] at
org.apache.flink.table.runtime.operators.python.aggregate.arrow.AbstractArrowPythonAggregateFunctionOperator.open(AbstractArrowPythonAggregateFunctionOperator.java:90)
~[?:?] at
org.apache.flink.table.runtime.operators.python.aggregate.arrow.stream.StreamArrowPythonGroupWindowAggregateFunctionOperator.open(StreamArrowPythonGroupWindowAggregateFunctionOperator.java:180)
~[?:?] at
org.apache.flink.streaming.runtime.tasks.OperatorChain.initializeStateAndOpenOperators(OperatorChain.java:426)
~[flink-dist_2.12-1.12.1.jar:1.12.1] at
org.apache.flink.streaming.runtime.tasks.StreamTask.lambda$beforeInvoke$2(StreamTask.java:535)
~[flink-dist_2.12-1.12.1.jar:1.12.1] at
org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.runThrowing(StreamTaskActionExecutor.java:50)
~[flink-dist_2.12-1.12.1.jar:1.12.1] at
org.apache.flink.streaming.runtime.tasks.StreamTask.beforeInvoke(StreamTask.java:525)
~[flink-dist_2.12-1.12.1.jar:1.12.1] at
org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:565)
~[flink-dist_2.12-1.12.1.jar:1.12.1] at
org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:755)
~[flink-dist_2.12-1.12.1.jar:1.12.1] at
org.apache.flink.runtime.taskmanager.Task.run(Task.java:570)
~[flink-dist_2.12-1.12.1.jar:1.12.1] at java.lang.Thread.run(Thread.java:748)
~[?:1.8.0_281] Suppressed: java.lang.NullPointerException at
org.apache.flink.table.runtime.operators.python.aggregate.arrow.AbstractArrowPythonAggregateFunctionOperator.dispose(AbstractArrowPythonAggregateFunctionOperator.java:105)
~[?:?] at
org.apache.flink.streaming.runtime.tasks.StreamTask.disposeAllOperators(StreamTask.java:783)
~[flink-dist_2.12-1.12.1.jar:1.12.1] at
org.apache.flink.streaming.runtime.tasks.StreamTask.runAndSuppressThrowable(StreamTask.java:762)
~[flink-dist_2.12-1.12.1.jar:1.12.1] at
org.apache.flink.streaming.runtime.tasks.StreamTask.cleanUpInvoke(StreamTask.java:681)
~[flink-dist_2.12-1.12.1.jar:1.12.1] at
org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:585)
~[flink-dist_2.12-1.12.1.jar:1.12.1] at
org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:755)
~[flink-dist_2.12-1.12.1.jar:1.12.1] at
org.apache.flink.runtime.taskmanager.Task.run(Task.java:570)
~[flink-dist_2.12-1.12.1.jar:1.12.1] at java.lang.Thread.run(Thread.java:748)
~[?:1.8.0_281]
{code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
