----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/34066/ -----------------------------------------------------------
Review request for samza. Repository: samza Description ------- used the maximum partition id across all containers as the total number of partitions for creating changelog topics Diffs ----- samza-core/src/main/scala/org/apache/samza/container/SamzaContainer.scala e8e830e99825ac9802552c43ec9579c01570f9ea samza-core/src/main/scala/org/apache/samza/job/local/ThreadJobFactory.scala 60ee36ff344200e89c34d9147c81c00650ec535e Diff: https://reviews.apache.org/r/34066/diff/ Testing ------- Unit tests Thanks, Guozhang Wang
