[ 
https://issues.apache.org/jira/browse/FLINK-26060?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17490852#comment-17490852
 ] 

Marios Trivyzas commented on FLINK-26060:
-----------------------------------------

Currently, we have removed support for *consumedOptions* param in 
*@ExecNodeMetadata* for StreamExecPython* nodes:

[https://github.com/apache/flink/pull/18624]

So we won't have configuration persisted in the json plan for those nodes.

If/when we decide to support them we need to add back the *consumedOptions.*

> Make Python specific exec nodes unsupported 
> --------------------------------------------
>
>                 Key: FLINK-26060
>                 URL: https://issues.apache.org/jira/browse/FLINK-26060
>             Project: Flink
>          Issue Type: Sub-task
>          Components: Table SQL / Runtime
>            Reporter: Francesco Guardiani
>            Assignee: Francesco Guardiani
>            Priority: Major
>              Labels: pull-request-available
>
> These nodes are using the old type system, which is going to be removed soon. 
> We should avoid supporting them in the persisted plan, as we cannot commit to 
> support them. Once migrated to the new type system, PyFlink won't need these 
> nodes anymore and will just rely on Table new function stack. For more 
> details, also check https://issues.apache.org/jira/browse/FLINK-25231



--
This message was sent by Atlassian Jira
(v8.20.1#820001)

Reply via email to