Updated Branches: refs/heads/master 53d9df7fa -> df6bd392a
Fix incorrect log message in SamzaAppMasterTaskManager. Signed-off-by: Jakob Glen 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/df6bd392 Tree: http://git-wip-us.apache.org/repos/asf/incubator-samza/tree/df6bd392 Diff: http://git-wip-us.apache.org/repos/asf/incubator-samza/diff/df6bd392 Branch: refs/heads/master Commit: df6bd392acb5dd1600d191a5157dd6cd54519463 Parents: 53d9df7 Author: Jakob Glen Homan <[email protected]> Authored: Fri Dec 20 13:01:10 2013 -0800 Committer: Jakob Glen Homan <[email protected]> Committed: Fri Dec 20 13:15:55 2013 -0800 ---------------------------------------------------------------------- .../org/apache/samza/job/yarn/SamzaAppMasterTaskManager.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-samza/blob/df6bd392/samza-yarn/src/main/scala/org/apache/samza/job/yarn/SamzaAppMasterTaskManager.scala ---------------------------------------------------------------------- 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 7a63a2b..9058210 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)
