This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 0c7659e [FLINK-19875][table][fs-connector] Integrate file compaction
to filesystem connector
add eee0d8e [FLINK-19727][table] Implement ParallelismProvider for sink
in blink planner
No new revisions were added by this update.
Summary of changes:
.../table/connector/sink/SinkFunctionProvider.java | 3 +-
.../table/connector/sink/OutputFormatProvider.java | 3 +-
.../plan/nodes/common/CommonPhysicalSink.scala | 63 ++++++-
.../plan/nodes/physical/batch/BatchExecSink.scala | 5 +-
.../nodes/physical/stream/StreamExecSink.scala | 5 +-
.../factories/TestValuesRuntimeFunctions.java | 27 +++
.../planner/factories/TestValuesTableFactory.java | 70 ++++++-
.../runtime/batch/table/TableSinkITCase.scala | 2 -
.../runtime/stream/table/TableSinkITCase.scala | 210 ++++++++++++++++++++-
9 files changed, 362 insertions(+), 26 deletions(-)
