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 8a7093b [FLINK-18126][python] Correct the exception handling of the
Python CompletableFuture
add d1ed9bf [FLINK-18207][FLINK-18185][table] Fix datagen connector
exactly-once bug and validation message
No new revisions were added by this update.
Summary of changes:
.../api/functions/StatefulSequenceSourceTest.java | 20 ++---
.../source/datagen/DataGeneratorSourceTest.java | 51 +++++++-----
flink-table/flink-table-api-java-bridge/pom.xml | 7 ++
.../table/factories/DataGenTableSourceFactory.java | 20 ++++-
.../factories/DataGenTableSourceFactoryTest.java | 97 ++++++++++++++++++++--
5 files changed, 152 insertions(+), 43 deletions(-)