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/paimon.git
from 59c038af79 [test] Fix the unstable
testNoChangelogProducerStreamingRandom (#4940)
add 43abe2da76 [flink] Introduce scan bounded to force bounded in
streaming job (#4941)
No new revisions were added by this update.
Summary of changes:
.../generated/flink_connector_configuration.html | 6 ++++++
.../paimon/flink/source/DataTableSource.java | 10 +++++-----
paimon-flink/paimon-flink-common/pom.xml | 4 ++++
.../paimon/flink/AbstractFlinkTableFactory.java | 22 +++++++++++++++-------
.../apache/paimon/flink/FlinkConnectorOptions.java | 8 ++++++++
.../paimon/flink/source/BaseDataTableSource.java | 18 +++++++++---------
.../paimon/flink/source/DataTableSource.java | 16 ++++++++--------
.../paimon/flink/source/FlinkTableSource.java | 6 +++---
.../paimon/flink/source/SystemTableSource.java | 19 +++++++++----------
.../apache/paimon/flink/BatchFileStoreITCase.java | 16 ++++++++++++++++
10 files changed, 83 insertions(+), 42 deletions(-)
