[GitHub] samza pull request #585: SAMZA-1788: Add LocationIdProvider abstraction.

GitHub user shanthoosh opened a pull request: https://github.com/apache/samza/pull/585 SAMZA-1788: Add LocationIdProvider abstraction. Currently in standalone, by default hostName of the standalone processor is used as LocationId. However, for containerized environments like azure c

[GitHub] samza pull request #582: Handle end of stream in BootstrapChooser

Github user asfgit closed the pull request at: https://github.com/apache/samza/pull/582 ---

[GitHub] samza pull request #584: SAMZA-1787: Refactor TaskStorageManager to use SSPM...

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

[GitHub] samza pull request #583: SAMZA-1786: Introduce metadata store abstraction.

GitHub user shanthoosh opened a pull request: https://github.com/apache/samza/pull/583 SAMZA-1786: Introduce metadata store abstraction. As a part of SEP-11, this patch adds MetadataStore interface to store task and container locality in both yarn and standalone deployment models. P

[GitHub] samza pull request #581: SAMZA-1785: ignore timeout exception during receive...

Github user lhaiesp closed the pull request at: https://github.com/apache/samza/pull/581 ---

[GitHub] samza pull request #582: Handle end of stream in BootstrapChooser

GitHub user bharathkk opened a pull request: https://github.com/apache/samza/pull/582 Handle end of stream in BootstrapChooser Handle end of stream envelopes in bootstrap chooser and don't invoke check offsets since offset of end of stream are not comparable. You can merge this pul

[GitHub] samza pull request #573: NO-JIRA: Change instances of "is catched up" to "is...

Github user asfgit closed the pull request at: https://github.com/apache/samza/pull/573 ---