GitHub user cameronlee314 opened a pull request:
https://github.com/apache/samza/pull/584
SAMZA-1787: Refactor TaskStorageManager to use SSPMetadataCache during init
Testing done:
Deployed test job with changelog with no existing file offset, verified
through logging that oldest offset was registered with the changelog consumer
in init stage for TaskStorageManager
Deployed test job with changelog with existing file offset, verified
through logging that file offset was registered with the changelog consumer in
init stage for TaskStorageManager
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/cameronlee314/samza
task_storage_manager_ssp_metadata
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/samza/pull/584.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 #584
----
commit 3a442170f6f8e2abfef3bebce6dfcb12ca2116be
Author: Cameron Lee <calee@...>
Date: 2018-07-26T23:32:09Z
SAMZA-1787: Refactor TaskStorageManager to use SSPMetadataCache during init
----
---
