This is an automated email from the ASF dual-hosted git repository. lincoln pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
from 6d17ba88556 [FLINK-29558][table-planner] Fix projection pushdown rule select nothing from source when no column is needed logically (#21704) add 5afc301bc64 [FLINK-30665][table] Planner supports row-level update No new revisions were added by this update. Summary of changes: .../table/planner/connectors/DynamicSinkUtils.java | 175 +++- .../operations/SqlToOperationConverter.java | 25 +- .../plan/abilities/sink/RowLevelDeleteSpec.java | 1 + ...evelDeleteSpec.java => RowLevelUpdateSpec.java} | 55 +- .../plan/abilities/sink/SinkAbilitySpec.java | 3 +- .../plan/nodes/exec/common/CommonExecSink.java | 10 +- .../factories/TestUpdateDeleteTableFactory.java | 398 +++++++-- ...st.java => SqlDdlToOperationConverterTest.java} | 701 +-------------- .../operations/SqlDmlToOperationConverterTest.java | 334 +++++++ .../operations/SqlOtherOperationConverterTest.java | 324 +++++++ .../SqlToOperationConverterTestBase.java | 148 ++++ .../planner/plan/batch/sql/RowLevelUpdateTest.java | 165 ++++ .../runtime/batch/sql/UpdateTableITCase.java | 150 ++++ .../runtime/stream/sql/UpdateTableITCase.java | 44 + .../planner/plan/batch/sql/RowLevelUpdateTest.xml | 973 +++++++++++++++++++++ 15 files changed, 2748 insertions(+), 758 deletions(-) copy flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/abilities/sink/{RowLevelDeleteSpec.java => RowLevelUpdateSpec.java} (60%) rename flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/operations/{SqlToOperationConverterTest.java => SqlDdlToOperationConverterTest.java} (79%) create mode 100644 flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/operations/SqlDmlToOperationConverterTest.java create mode 100644 flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/operations/SqlOtherOperationConverterTest.java create mode 100644 flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/operations/SqlToOperationConverterTestBase.java create mode 100644 flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/batch/sql/RowLevelUpdateTest.java create mode 100644 flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/runtime/batch/sql/UpdateTableITCase.java create mode 100644 flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/runtime/stream/sql/UpdateTableITCase.java create mode 100644 flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/batch/sql/RowLevelUpdateTest.xml