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 59e73e0 [FLINK-19721] Let RpcGatewayRetrievers in
DispatcherResourceManagerComponent use ExponentialBackoffRetryStrategy
add 8d7e323 [FLINK-19726][table-planner] Implement DataStream and Source
Providers
No new revisions were added by this update.
Summary of changes:
.../plan/nodes/common/CommonPhysicalSink.scala | 64 ++++++-----
.../common/CommonPhysicalTableSourceScan.scala | 9 +-
.../planner/factories/TestFileSourceFactory.java | 128 +++++++++++++++++++++
.../planner/factories/TestValuesTableFactory.java | 82 ++++++++-----
.../org.apache.flink.table.factories.Factory | 1 +
.../runtime/batch/sql/TableSourceITCase.scala | 55 +++++++++
.../runtime/batch/table/TableSinkITCase.scala | 12 +-
.../operators/sink/SinkNotNullEnforcer.java | 69 +++++++++++
.../table/runtime/operators/sink/SinkOperator.java | 42 +------
9 files changed, 366 insertions(+), 96 deletions(-)
create mode 100644
flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/factories/TestFileSourceFactory.java
create mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/sink/SinkNotNullEnforcer.java
