[
https://issues.apache.org/jira/browse/FLINK-23765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17398542#comment-17398542
]
Yuan Mei commented on FLINK-23765:
----------------------------------
Aug 13 06:24:26 at
org.apache.flink.table.runtime.operators.python.table.PythonTableFunctionOperator.emitResult(PythonTableFunctionOperator.java:193)
Aug 13 06:24:26 at
org.apache.flink.streaming.api.operators.python.AbstractPythonFunctionOperator.invokeFinishBundle(AbstractPythonFunctionOperator.java:351)
Aug 13 06:24:26 at
org.apache.flink.streaming.api.operators.python.AbstractPythonFunctionOperator.finish
I think it may relate to how to handle data after finish
In the current contract, there should not be any more input data after
function.finish() is called.
[~gaoyunhaii], please correct me if I am wrong
> PythonTableFunctionOperatorTestBase java.lang.NullPointerException
> -------------------------------------------------------------------
>
> Key: FLINK-23765
> URL: https://issues.apache.org/jira/browse/FLINK-23765
> Project: Flink
> Issue Type: Bug
> Components: API / Python
> Reporter: Yuan Mei
> Priority: Blocker
>
>
>
> PythonTableFunctionOperatorTest>PythonTableFunctionOperatorTestBase.testFinishBundleTriggeredByTime:147
> » NullPointer
> PythonTableFunctionOperatorTest>PythonTableFunctionOperatorTestBase.testFinishBundleTriggeredOnCheckpoint:93
> » NullPointer
>
> PythonTableFunctionOperatorTest>PythonTableFunctionOperatorTestBase.testLeftJoin:179
> » NullPointer
>
> PythonTableFunctionOperatorTest>PythonTableFunctionOperatorTestBase.testRetractionFieldKept:68
> » NullPointer
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
