This is an automated email from the ASF dual-hosted git repository.
xuyangzhong pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from f0ed3f7cef3 [FLINK-37705][rest] JobPlanInfo properties spec adjustments
add 9fb7cc38acd [FLINK-37542][table-planner] Support sink reuse in
streaming mode (#26380)
No new revisions were added by this update.
Summary of changes:
.../generated/optimizer_config_configuration.html | 2 +-
.../table/api/config/OptimizerConfigOptions.java | 2 +-
.../flink/table/planner/plan/reuse/SinkReuser.java | 48 ++++++--
.../nodes/physical/stream/StreamPhysicalSink.scala | 2 +-
.../table/planner/plan/reuse/SubplanReuser.scala | 4 +-
.../planner/plan/common/SinkReuseTestBase.java | 2 +-
.../plan/stream/sql/StreamSinkReuseTest.java | 115 +++++++++++++++++
.../runtime/common/sql/SinkReuseITCase.java | 2 +-
.../sql/StreamSinkReuseTest.xml} | 137 +++++++++++++++------
9 files changed, 261 insertions(+), 53 deletions(-)
create mode 100644
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/stream/sql/StreamSinkReuseTest.java
copy
flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/{batch/sql/BatchSinkReuseTest.xml
=> stream/sql/StreamSinkReuseTest.xml} (77%)
