You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@samza.apache.org by shanthoosh <gi...@git.apache.org> on 2018/10/15 17:11:36 UTC
[GitHub] samza pull request #726: SAMZA-1952: StreamPartitionCountMonitor for standal...
GitHub user shanthoosh opened a pull request:
https://github.com/apache/samza/pull/726
SAMZA-1952: StreamPartitionCountMonitor for standalone.
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 <sp...@...>
Date: 2018-09-25T23:20:50Z
SAMZA-1952: StreamPartitionCountMonitor for standalone.
----
---
[GitHub] samza pull request #726: SAMZA-1952: StreamPartitionCountMonitor for standal...
Posted by shanthoosh <gi...@git.apache.org>.
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 <sp...@...>
Date: 2018-09-25T23:20:50Z
SAMZA-1952: StreamPartitionCountMonitor for standalone.
----
---
[GitHub] samza pull request #726: SAMZA-1952: StreamPartitionCountMonitor for standal...
Posted by shanthoosh <gi...@git.apache.org>.
Github user shanthoosh closed the pull request at:
https://github.com/apache/samza/pull/726
---
[GitHub] samza pull request #726: SAMZA-1952: StreamPartitionCountMonitor for standal...
Posted by asfgit <gi...@git.apache.org>.
Github user asfgit closed the pull request at:
https://github.com/apache/samza/pull/726
---