You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by jm...@apache.org on 2017/09/19 21:44:06 UTC
samza git commit: SAMZA-1414: SamzaContainer log statements
incorrectly expect containerId is a number
Repository: samza
Updated Branches:
refs/heads/master 0f06da1f8 -> 89f8ca4ec
SAMZA-1414: SamzaContainer log statements incorrectly expect containerId is a number
Correctly log ID as a string in SamzaContainer.
jmakes
Author: Daniel Nishimura <dn...@gmail.com>
Reviewers: Jacob Maes <jm...@linkedin.com>
Closes #298 from dnishimura/samza-1414
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/89f8ca4e
Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/89f8ca4e
Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/89f8ca4e
Branch: refs/heads/master
Commit: 89f8ca4ec1c72540596ad73e640e331b62b47a93
Parents: 0f06da1
Author: Daniel Nishimura <dn...@gmail.com>
Authored: Tue Sep 19 14:43:55 2017 -0700
Committer: Jacob Maes <jm...@linkedin.com>
Committed: Tue Sep 19 14:43:55 2017 -0700
----------------------------------------------------------------------
.../main/scala/org/apache/samza/container/SamzaContainer.scala | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/samza/blob/89f8ca4e/samza-core/src/main/scala/org/apache/samza/container/SamzaContainer.scala
----------------------------------------------------------------------
diff --git a/samza-core/src/main/scala/org/apache/samza/container/SamzaContainer.scala b/samza-core/src/main/scala/org/apache/samza/container/SamzaContainer.scala
index b830579..628d7f6 100644
--- a/samza-core/src/main/scala/org/apache/samza/container/SamzaContainer.scala
+++ b/samza-core/src/main/scala/org/apache/samza/container/SamzaContainer.scala
@@ -841,10 +841,10 @@ class SamzaContainer(
localityManager.writeContainerToHostMapping(containerContext.id, hostInet.getHostName, jmxUrl, jmxTunnelingUrl)
} catch {
case uhe: UnknownHostException =>
- warn("Received UnknownHostException when persisting locality info for container %d: " +
+ warn("Received UnknownHostException when persisting locality info for container %s: " +
"%s" format (containerContext.id, uhe.getMessage)) //No-op
case unknownException: Throwable =>
- warn("Received an exception when persisting locality info for container %d: " +
+ warn("Received an exception when persisting locality info for container %s: " +
"%s" format (containerContext.id, unknownException.getMessage))
}
}