This is an automated email from the ASF dual-hosted git repository.
jark pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from dc0c416 [FLINK-21101][Azure] Add nightly profile to run all tests
with the adaptive scheduler
add 3ac8364 [FLINK-21005][table] Introduce new runtime provider for
unified Sink API and implement in planner
No new revisions were added by this update.
Summary of changes:
.../connector/sink/DataStreamSinkProvider.java | 2 +-
...OutputFormatProvider.java => SinkProvider.java} | 29 ++-
.../plan/nodes/exec/common/CommonExecSink.java | 229 ++++++++++++++-------
...FileSourceFactory.java => TestFileFactory.java} | 79 ++++++-
.../MultipleInputNodeCreationProcessorTest.java | 2 +-
.../org.apache.flink.table.factories.Factory | 2 +-
.../runtime/batch/sql/TableSourceITCase.scala | 5 +-
.../runtime/stream/table/TableSinkITCase.scala | 94 +++++++++
.../operators/sink/SinkNotNullEnforcer.java | 11 +-
.../table/runtime/operators/sink/SinkOperator.java | 12 +-
10 files changed, 348 insertions(+), 117 deletions(-)
copy
flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/sink/{OutputFormatProvider.java
=> SinkProvider.java} (61%)
rename
flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/factories/{TestFileSourceFactory.java
=> TestFileFactory.java} (69%)
