----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/47073/ -----------------------------------------------------------
Review request for samza, Boris Shkolnik, Chris Pettitt, Jake Maes, Navina Ramesh, Jagadish Venkatraman, Xinyu Liu, and Yi Pan (Data Infrastructure). Bugs: SAMZA-946 https://issues.apache.org/jira/browse/SAMZA-946 Repository: samza Description ------- SAMZA-946 - ConcurrentModificationException in TaskAssignmentManager * Copy the map before returning it * A little cleanup in TaskAssignment manager * Also fixing a javadoc issue introduced in SAMZA-944, oops Diffs ----- samza-core/src/main/java/org/apache/samza/config/DefaultChooserConfig.java d242d1476841caf5c82ddf19c51c992a36d9591b samza-core/src/main/java/org/apache/samza/container/grouper/task/TaskAssignmentManager.java ec5cf3da4d1967cf586cdf074262a1f42f1efb75 samza-core/src/test/java/org/apache/samza/container/grouper/task/TestTaskAssignmentManager.java 7f834941862e24649e00d804627f87cf733b7eb3 Diff: https://reviews.apache.org/r/47073/diff/ Testing ------- Added a new test which reproduces the exception and ran all tests. Thanks, Jake Maes