GitHub user shanthoosh reopened a pull request:
https://github.com/apache/samza/pull/726
SAMZA-1952: StreamPartitionCountMonitor for standalone.
This patch adds the capability to detect the partition change of the input
streams of a stateless standalone jobs and trigger a re-balancing phase(which
will essentially account for new partitions from input stream and distribute it
to the live processors of the group).
Existing partition count detection of input streams is broken in yarn for
stateful jobs. This will be addressed for both yarn and standalone as a part of
#622
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/shanthoosh/samza
stream_partition_count_monitor_for_standalone
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/samza/pull/726.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #726
----
commit 1c4be058f101fba63ad5d9f8a754a749adf8bb61
Author: Shanthoosh Venkataraman <spvenkat@...>
Date: 2018-09-25T23:20:50Z
SAMZA-1952: StreamPartitionCountMonitor for standalone.
----
---
