[ https://issues.apache.org/jira/browse/FLINK-35905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17869845#comment-17869845 ]
xuyang commented on FLINK-35905: -------------------------------- Yes, [~au_miner] you're right, currently Flink has not supported a plugin system for custom operators and rules. It is only a future plan... For more details, you can refer to the comments in [{{{}org.apache.flink.table.module.Module{}}}{_}{{}}{_}|https://github.com/apache/flink/blob/82b628d4730eef32b2f7a022e3b73cb18f950e6e/flink-table/flink-table-common/src/main/java/org/apache/flink/table/module/Module.java#L31] and [FLIP-68|https://cwiki.apache.org/confluence/display/FLINK/FLIP-68%3A+Extend+Core+Table+System+with+Pluggable+Modules]. > Flink physical operator replacement support > ------------------------------------------- > > Key: FLINK-35905 > URL: https://issues.apache.org/jira/browse/FLINK-35905 > Project: Flink > Issue Type: Bug > Components: API / Scala, Table SQL / API > Affects Versions: 1.15.0 > Environment: Flink1.15 and so on > Reporter: Wang Qilong > Priority: Major > > Does Flinksql provide some SPI implementations that support custom physical > operators, such as customizing a new StreamExecFileSourceScan and supporting > rule injection for converting logical operators to physical operators -- This message was sent by Atlassian Jira (v8.20.10#820010)