Hey Yi,
Thanks for the detailed comment and the summary!
To address your comments:
1) The current names are GroupByPartitionWithFixedTaskNum and
GroupBySystemStreamPartitionWithFixedTaskNum. Instead of
FixedTasksGroupByPartition
and FixedTasksGroupBySystemStreamPartition, how about GroupByPartit
GitHub user sborya opened a pull request:
https://github.com/apache/samza/pull/231
SAMZA-1337: Use StreamTask with the LocalApplicationRunner
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/sborya/samza LocalAppRunnerWithStreamTa
Hi, Dong and everyone,
Thanks for the detailed discussion on SEP-5! Really appreciate the thorough
consideration on this issue. I also noticed that Dong has updated the SEP-5
wiki to clarify:
1) SEP-5 provides a solution to retain the same number of task/state w/o
re-partitioning (as illustrated i
