[
https://issues.apache.org/jira/browse/FLINK-21944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-21944.
---------------------------
Resolution: Fixed
Fixed in
- master via 0e04b2e736d959471270ee77266d0b638189e828
- release-1.12 via 719bf5ea469d55cf162b238105b767774d01edce
> 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
> Assignee: Dian Fu
> Priority: Major
> 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)
