----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/34888/#review86044 -----------------------------------------------------------
samza-core/src/main/scala/org/apache/samza/system/SystemConsumersMetrics.scala <https://reviews.apache.org/r/34888/#comment137897> change to "registerSystemStreamPartition"? - Yan Fang On June 1, 2015, 1:27 p.m., József Márton Jung wrote: > > ----------------------------------------------------------- > This is an automatically generated e-mail. To reply, visit: > https://reviews.apache.org/r/34888/ > ----------------------------------------------------------- > > (Updated June 1, 2015, 1:27 p.m.) > > > Review request for samza. > > > Repository: samza > > > Description > ------- > > Fix for issue described in > [SAMZA-691](https://issues.apache.org/jira/browse/SAMZA-691): > > messages-chosen counter in SystemConsumersMetrics registerSystemStream > without identifying the partition > > > Diffs > ----- > > samza-core/src/main/scala/org/apache/samza/system/SystemConsumers.scala > 1ec5e32 > > samza-core/src/main/scala/org/apache/samza/system/SystemConsumersMetrics.scala > a63349c > > Diff: https://reviews.apache.org/r/34888/diff/ > > > Testing > ------- > > > Thanks, > > József Márton Jung > >