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
----
---
