GitHub user cameronlee314 opened a pull request: https://github.com/apache/samza/pull/483
adding getNewestOffset API to StreamMetadataCache and using it in Tas⦠â¦kStorageManager Testing done: ./gradlew clean check ./bin/integration-tests.sh Implemented getNewestOffset with a custom admin and verified that newest offsets get correctly written and used when restoring stores You can merge this pull request into a Git repository by running: $ git pull https://github.com/cameronlee314/samza metadatacache Alternatively you can review and apply these changes as the patch at: https://github.com/apache/samza/pull/483.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #483 ---- commit f967ce4554474976bdeb4c6eb63a1bdd1a8ab001 Author: Cameron Lee <calee@...> Date: 2018-04-21T00:11:25Z adding getNewestOffset API to StreamMetadataCache and using it in TaskStorageManager ---- ---