You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "Wang Qilong (Jira)" <ji...@apache.org> on 2024/07/28 08:30:00 UTC

[jira] [Created] (FLINK-35905) Flink physical operator replacement support

Wang Qilong created FLINK-35905:
-----------------------------------

             Summary: 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


I have been studying the FlinkSQL source code recently and have learned about the execution process of FlinkSQL, which has led to a question:
Does Flinksql provide some SPI implementations that support custom physical operators, such as customizing a FileSourceScanExec in the execPhysicalPlan layer?



--
This message was sent by Atlassian Jira
(v8.20.10#820010)