tree be32f322faff41e4ae7615990cafce564f841a1f
parent a2827db501afc98d420ada50cf7a914436b8dd66
author mynameborat <bharath.kumarasubramanian@gmail.com> 1616801148 -0700
committer GitHub <noreply@github.com> 1616801148 -0700
gpgsig -----BEGIN PGP SIGNATURE-----
 
 wsBcBAABCAAQBQJgXm18CRBK7hj4Ov3rIwAAdHIIAB4KA0Wdm38b2eoze/wSv66q
 LHrFt4w3HqTT+vpfFrwhZsFtDzxuzCAm1bbOzDNIZ+OooqbuehzSgr3rStzZrkrC
 ycLNnus0VWcx74Z2sykJgcHhkg6k93cizZECfuPko4BBOI/75ivbYCM4a15ij2QY
 3ZUYReolwQk0ndMWb2Qo4/9a/Huc6Y3VXIjQvzZ0vInCpJ3Kc7gUYd5Z0mijm7k6
 a4Q/B0wLmBTBpQu30wiS068c3+TNoRq4a5yiXIt6e5pEsH3TotnE8sS/X+bRzBgt
 1+fpeWyYgeqGctnNUNwwwwjpAe345BcsKbBRFjyQoHQNxtoXBzdI4O94bIXdvdU=
 =Md8A
 -----END PGP SIGNATURE-----
 

SAMZA-2638: Skip container stop/restart for processors that have same work assignment across rebalances (#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 for explanations
- Add helper methods in JobModelUtil for work assignment comparison