From df6bd392acb5dd1600d191a5157dd6cd54519463 Mon Sep 17 00:00:00 2001 From: Jakob Glen Homan Date: Fri, 20 Dec 2013 13:01:10 -0800 Subject: [PATCH] Fix incorrect log message in SamzaAppMasterTaskManager. Signed-off-by: Jakob Glen Homan --- .../org/apache/samza/job/yarn/SamzaAppMasterTaskManager.scala | 2 +- 1 file changed, 1 insertion(+), 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 index 7a63a2b856..905821003d 100644 --- 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)