[GitHub] [flink-table-store] tsreaper opened a new pull request, #358: [FLINK-29842] Change commitIdentifier in Table Store snapshot to long value

[GitBox <gi...@apache.org>]

tsreaper opened a new pull request, #358:
URL: https://github.com/apache/flink-table-store/pull/358

   (Cherry-picked from #346)
   
   Currently `commitIdentifier` in `Snapshot` is a `String` value. However there are many scenarios where we need to compare two identifiers to find out which one is newer. For example
   
   * In FLINK-29840, we need to store the latest modified commit for each writer. Only when the latest snapshot is newer than this commit can we safely close the writer.
   * In FLINK-29805, we can read the commit identifier of the latest snapshot. All identifiers older than that should be filtered out.
   * In FLINK-29752, we need to trigger full compaction once in a few commits. We can read the latest commit identifier and compare it with the full compaction identifier to check if full compaction is successfully committed.
    


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [flink-table-store] tsreaper merged pull request #358: [FLINK-29842] Change commitIdentifier in Table Store snapshot to long value

[GitBox <gi...@apache.org>]

tsreaper merged PR #358:
URL: https://github.com/apache/flink-table-store/pull/358


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org