SAMZA-946 - ConcurrentModificationException in TaskAssignmentManager when partition...
authorJacob Maes <jacob.maes@gmail.com>
Fri, 6 May 2016 19:32:57 +0000 (12:32 -0700)
committerNavina Ramesh <nramesh@linkedin.com>
Fri, 6 May 2016 19:32:57 +0000 (12:32 -0700)
commit9d3a687948d8e16550a91d8a560c88a3ac5e9e50
treeca1bda63ea0071e45d55e670d62252c05c5eb793
parent5a673604abe129cfab124265af7eba3eb05fd83b
SAMZA-946 - ConcurrentModificationException in TaskAssignmentManager when partition count changes.
samza-core/src/main/java/org/apache/samza/config/DefaultChooserConfig.java
samza-core/src/main/java/org/apache/samza/container/grouper/task/TaskAssignmentManager.java
samza-core/src/test/java/org/apache/samza/container/grouper/task/TestTaskAssignmentManager.java