mynameborat opened a new pull request #1478:
URL: https://github.com/apache/samza/pull/1478
**Problem**:
As part of rebalance, we always expire the current work assignment and
proceed to signal consensus and start the container with new work assignment.
It is inefficient for the processors to do the above when there is no changes
in the work assignment between the active job model & the proposed job model.
**Changes**:
- Processors perform onJobModelExpired and onNewJobModel only if there are
changes to their work assignment across the active and proposed job model.
- Processors no longer shutdown if they are not part of job model. Refer to
the [SAMZA-2638](https://issues.apache.org/jira/browse/SAMZA-2638) for
explanations
- Add helper methods in `JobModelUtil` for work assignment comparison
**Tests**:
- Unit tests for job model expiration
- Unit tests for on new job model
- Unit tests for job model version change flow
- Unit tests for container model comparison
**API Changes**: None
**Usage Instructions**: None
**Upgrade Instructions**: None
--
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:
[email protected]
