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/03/03 07:35:27 UTC

[flink-table-store] branch master updated (57134d3 -> e7d2672)

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 57134d3  [FLINK-26247] Optimize expire by only reading new changes in a snapshot
     add e7d2672  [hotfix] Fix ClassCastException when StoreSinkWriter#writeToFileStore encountered non-pk record

No new revisions were added by this update.

Summary of changes:
 .../store/connector/sink/StoreSinkWriter.java      |  4 +--
 .../table/store/connector/sink/StoreSinkTest.java  | 32 ++++++++++++++++++--
 .../table/store/connector/sink/TestFileStore.java  | 35 ++++++++++++++++++----
 3 files changed, 60 insertions(+), 11 deletions(-)