You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by GitBox <gi...@apache.org> on 2019/05/20 22:56:42 UTC
[GitHub] [samza] dnishimura opened a new pull request #1042: SAMZA-2201 :
Startpoints - Integrate fan out with job coordinators
dnishimura opened a new pull request #1042: SAMZA-2201 : Startpoints - Integrate fan out with job coordinators
URL: https://github.com/apache/samza/pull/1042
This PR integrates the Startpoint fan out implemented in PR #1027.
Supported job coordinators:
- `ClusterBasedJobCoordinator`
- `ZkJobCoordinator`
Unsupported job coordinators:
- `PassthroughJobCoordinator` - Offset management is external to Samza.
- `AzureJobCoordinator` - Currently, the coordination logic is broken. Will link ticket here with explanation.
Next steps after this PR: Investigate if it makes sense to separate fan out logic from the `StartpointManager`
@shanthoosh @cameronlee314 - Please take a look when you get a chance.
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
With regards,
Apache Git Services