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

Posted to commits@flink.apache.org by ar...@apache.org on 2025/06/12 07:02:44 UTC

(flink) branch master updated (f6fbafad2ec -> 623f172ab4b)

This is an automated email from the ASF dual-hosted git repository.

arvid pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


    from f6fbafad2ec [FLINK-37896][table-planner] Introduce a new trait derived from sink to source to check whether the downstream operators can accept duplicate data (#26648)
     add 623f172ab4b [FLINK-37933][table] Move TransformationScan/SinkProvider out of planner (#26656)

No new revisions were added by this update.

Summary of changes:
 .../org/apache/flink/table/connector/ProviderContext.java    |  3 +--
 .../table/connector/sink}/TransformationSinkProvider.java    | 12 ++++--------
 .../table/connector/source}/TransformationScanProvider.java  | 12 +++---------
 .../flink/table/planner/connectors/ExternalDynamicSink.java  |  1 +
 .../table/planner/connectors/ExternalDynamicSource.java      |  1 +
 .../table/planner/plan/nodes/exec/common/CommonExecSink.java |  2 +-
 .../plan/nodes/exec/common/CommonExecTableSourceScan.java    |  2 +-
 .../table/planner/utils/DynamicPartitionPruningUtils.java    |  2 +-
 8 files changed, 13 insertions(+), 22 deletions(-)
 rename flink-table/{flink-table-api-java-bridge => flink-table-common}/src/main/java/org/apache/flink/table/connector/ProviderContext.java (94%)
 rename flink-table/{flink-table-planner/src/main/java/org/apache/flink/table/planner/connectors => flink-table-common/src/main/java/org/apache/flink/table/connector/sink}/TransformationSinkProvider.java (85%)
 rename flink-table/{flink-table-planner/src/main/java/org/apache/flink/table/planner/connectors => flink-table-common/src/main/java/org/apache/flink/table/connector/source}/TransformationScanProvider.java (80%)