This is an automated email from the ASF dual-hosted git repository.
czweng pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink-table-store.git
from 0a193a81 [FLINK-29805] Fix incorrect snapshot filter when snapshots
are committing too slow
add 9b5dc0ce [FLINK-29876] Explicitly throw exception from Table Store
sink when unaligned checkpoint is enabled or at least once checkpoint mode is
used
No new revisions were added by this update.
Summary of changes:
docs/content/docs/development/write-table.md | 2 +-
.../table/store/connector/sink/StoreSink.java | 20 ++++++++
.../table/store/connector/CatalogITCaseBase.java | 4 +-
.../CompositePkAndMultiPartitionedTableITCase.java | 19 ++++----
.../store/connector/FileStoreTableITCase.java | 8 +++-
.../table/store/connector/LookupJoinITCase.java | 4 +-
.../table/store/connector/MappingTableITCase.java | 4 +-
.../store/connector/ReadWriteTableITCase.java | 17 +++----
.../store/connector/ReadWriteTableTestBase.java | 5 +-
.../store/connector/StreamingWarehouseITCase.java | 4 +-
.../store/connector/TableEnvironmentTestUtils.java | 54 ++++++++++++++++++++++
.../table/store/connector/TableStoreTestBase.java | 3 +-
.../store/connector/sink/SinkSavepointITCase.java | 5 +-
.../table/store/kafka/KafkaTableTestBase.java | 4 ++
14 files changed, 123 insertions(+), 30 deletions(-)
create mode 100644
flink-table-store-connector/src/test/java/org/apache/flink/table/store/connector/TableEnvironmentTestUtils.java
