Fix incorrect log message in SamzaAppMasterTaskManager.

Signed-off-by: Jakob Glen Homan <[email protected]>
zmyer · Dec 20, 2013 · df6bd39 · df6bd39
1 parent 53d9df7
commit df6bd39
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/samza-yarn/src/main/scala/org/apache/samza/job/yarn/SamzaAppMasterTaskManager.scala b/samza-yarn/src/main/scala/org/apache/samza/job/yarn/SamzaAppMasterTaskManager.scala
@@ -110,7 +110,7 @@ class SamzaAppMasterTaskManager(clock: () => Long, config: Config, state: SamzaA
       case Some(taskId) => {
         info("Got available task id (%d) for container: %s" format (taskId, container))
         val streamsAndPartitionsForTask = Util.getStreamsAndPartitionsForContainer(taskId, state.taskCount, allSystemStreamPartitions)
-        info("Claimed partitions %s for container ID %s" format (allSystemStreamPartitions, taskId))
+        info("Claimed partitions %s for container ID %s" format (streamsAndPartitionsForTask, taskId))
         val cmdBuilderClassName = config.getCommandClass.getOrElse(classOf[ShellCommandBuilder].getName)
         val cmdBuilder = Class.forName(cmdBuilderClassName).newInstance.asInstanceOf[CommandBuilder]
           .setConfig(config)