Bharath Kumarasubramanian

Please fill out the description for the change as per https://cwiki.apache.org/confluence/display/SAMZA/SEP-25%3A+PR+Title+And+Description+Guidelines. Looks like the tests are failing. Can you investigate to make sure it is not related to the version...

@perkss Have you tested with deploying jobs on top of the existing tests?

Can you please update the description following the [guideline](https://cwiki.apache.org/confluence/display/SAMZA/SEP-25%3A+PR+Title+And+Description+Guidelines)?

> @mynameborat Thanks for the reminder! The description has been added now. Thank you! It will be useful to describe the scenario where this is problematic and provide some context...

I'd prefer to not introduce force cleaning optional internal config for more combination of our stores properties (we already have one for logged store and now we have one for...

Is this PR still needed? Lets close it if its not.

Is this PR still needed?

Not sure if this will work in all scenarios. In our LI rewriter system expansion, the rewriter would not expand the side input system since it wouldn't be aware of...

> @mynameborat Good point, but we can fix that in the rewriter by making it aware of systems for side inputs (and probably for changelogs too). Would that work? I...

1. PartitionCountMonitor gets instantiated with the list of input streams to monitor. ClusterBasedJobCoordinator[1] and ZkJobCoordinator[2] are the ones that construct it and uses `task.inputs` to determine the input streams. We...