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 f27c221 [FLINK-25141][docs] Add es sink parallelism option
add 5b16a8f [FLINK-25178][table] Throw exception when managed table sink
needs checkpointing
No new revisions were added by this update.
Summary of changes:
.../python/ChainingOptimizingExecutor.java | 5 +++
.../apache/flink/table/delegation/Executor.java | 7 ++++
.../org/apache/flink/table/utils/ExecutorMock.java | 5 +++
.../table/factories/TestManagedTableFactory.java | 43 +++++++++++++++++++++-
.../table/planner/delegation/DefaultExecutor.java | 5 +++
.../table/planner/delegation/PlannerBase.scala | 10 +++++
.../planner/plan/batch/sql/TableSinkTest.scala | 35 ++++++++++++++++++
.../planner/plan/stream/sql/TableSinkTest.scala | 41 +++++++++++++++++++++
.../flink/table/planner/utils/TableTestBase.scala | 24 ++++++++++++
9 files changed, 174 insertions(+), 1 deletion(-)
