----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/51250/ -----------------------------------------------------------
Review request for samza. Repository: samza Description ------- Support container restart when partition count diff happens. Diffs ----- samza-core/src/main/java/org/apache/samza/coordinator/StreamPartitionCountMonitor.java 8652465ca6764bc69a2767bc3a4f436ca9f8a401 samza-core/src/main/java/org/apache/samza/job/model/JobModel.java dbd6dcc41644e9ea1e6a12dcd18f44ef2e63bc72 samza-core/src/main/scala/org/apache/samza/coordinator/JobCoordinator.scala ba38b5cfa4e61b5513ce38dd2be32438b62cd7ce samza-yarn/src/main/java/org/apache/samza/job/yarn/YarnClusterResourceManager.java 96d3d7cc2853356a338dc25067f01440c938e216 samza-yarn/src/main/java/org/apache/samza/job/yarn/YarnContainerRunner.java dacc52de0a34498a715a299bc69c95aebd1b08ba Diff: https://reviews.apache.org/r/51250/diff/ Testing ------- Thanks, Xiang Fu
