You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by lz...@apache.org on 2022/07/19 06:44:10 UTC

[flink-table-store] branch master updated (4d36d8dc -> f34be4ba)

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-table-store.git


    from 4d36d8dc [FLINK-28579] Supports predicate testing for new columns
     add f34be4ba [FLINK-28582] Check LSM tree structure when multiple jobs are committing into the same bucket

No new revisions were added by this update.

Summary of changes:
 .../table/store/connector/sink/StoreSink.java      |  13 +-
 .../flink/table/store/file/AbstractFileStore.java  |   8 +-
 .../table/store/file/AppendOnlyFileStore.java      |   7 ++
 .../flink/table/store/file/KeyValueFileStore.java  |   1 +
 .../table/store/file/data/DataFileWriter.java      |   8 ++
 .../table/store/file/manifest/ManifestEntry.java   |  43 +++++++
 .../file/operation/AbstractFileStoreScan.java      |  28 +----
 .../store/file/operation/FileStoreCommit.java      |   2 +
 .../store/file/operation/FileStoreCommitImpl.java  | 134 +++++++++++++++------
 .../store/file/operation/FileStoreExpireImpl.java  |   9 +-
 .../table/store/file/utils/SnapshotManager.java    |  16 ++-
 .../flink/table/store/table/sink/TableCommit.java  |   5 +
 .../flink/table/store/file/TestFileStore.java      |  20 ++-
 .../store/file/operation/FileStoreCommitTest.java  |  87 ++++++++++---
 .../store/file/operation/TestCommitThread.java     |  50 ++++++--
 .../file/utils/TestAtomicRenameFileSystem.java     |  10 +-
 16 files changed, 334 insertions(+), 107 deletions(-)