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