Updated Branches: refs/heads/master 4bf3f5eb0 -> c988f4f40
SAMZA-99: BootstrappingChooser: Malformed string format log entry Signed-off-by: Jakob Homan <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/incubator-samza/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-samza/commit/c988f4f4 Tree: http://git-wip-us.apache.org/repos/asf/incubator-samza/tree/c988f4f4 Diff: http://git-wip-us.apache.org/repos/asf/incubator-samza/diff/c988f4f4 Branch: refs/heads/master Commit: c988f4f408303f6c7946e8f8b0229617128b2fe0 Parents: 4bf3f5e Author: Jim Huang <[email protected]> Authored: Sun Dec 8 15:15:52 2013 -0800 Committer: Jakob Homan <[email protected]> Committed: Sun Dec 8 15:24:15 2013 -0800 ---------------------------------------------------------------------- .../org/apache/samza/system/chooser/BootstrappingChooser.scala | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-samza/blob/c988f4f4/samza-core/src/main/scala/org/apache/samza/system/chooser/BootstrappingChooser.scala ---------------------------------------------------------------------- diff --git a/samza-core/src/main/scala/org/apache/samza/system/chooser/BootstrappingChooser.scala b/samza-core/src/main/scala/org/apache/samza/system/chooser/BootstrappingChooser.scala index 2517e16..e875744 100644 --- a/samza-core/src/main/scala/org/apache/samza/system/chooser/BootstrappingChooser.scala +++ b/samza-core/src/main/scala/org/apache/samza/system/chooser/BootstrappingChooser.scala @@ -98,7 +98,7 @@ class BootstrappingChooser( def stop = wrapped.stop override def register(systemStreamPartition: SystemStreamPartition, lastReadOffset: String) { - debug("Registering stream partition with last read offset: %, %s" format (systemStreamPartition, lastReadOffset)) + debug("Registering stream partition with last read offset: %s, %s" format (systemStreamPartition, lastReadOffset)) // If the last offset read is the same as the latest offset in the SSP, // then we're already at head for this SSP, so remove it from the lag list. @@ -204,4 +204,4 @@ class BootstrappingChooserMetrics(val registry: MetricsRegistry = new MetricsReg def setLagCount(systemStream: SystemStream, getValue: () => Int) { newGauge("%s-%s-lagging-partitions" format (systemStream.getSystem, systemStream.getStream), getValue) } -} \ No newline at end of file +}
