Repository: samza Updated Branches: refs/heads/master 8a18a708a -> f5c8c56b4
SAMZA-1208 - IllegalFormatConversionException in LocalContainerRunner Author: Navina Ramesh <[email protected]> Reviewers: Xinyu Liu <[email protected]>, Prateek Maheshwari <[email protected]> Closes #121 from navina/SAMZA-1208 Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/f5c8c56b Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/f5c8c56b Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/f5c8c56b Branch: refs/heads/master Commit: f5c8c56b49d8b01b560699bf2b0fe4c592b534bb Parents: 8a18a70 Author: Navina Ramesh <[email protected]> Authored: Wed Apr 12 18:40:01 2017 -0700 Committer: nramesh <[email protected]> Committed: Wed Apr 12 18:40:01 2017 -0700 ---------------------------------------------------------------------- .../main/java/org/apache/samza/runtime/LocalContainerRunner.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/samza/blob/f5c8c56b/samza-core/src/main/java/org/apache/samza/runtime/LocalContainerRunner.java ---------------------------------------------------------------------- diff --git a/samza-core/src/main/java/org/apache/samza/runtime/LocalContainerRunner.java b/samza-core/src/main/java/org/apache/samza/runtime/LocalContainerRunner.java index d790fb1..d8a6ecd 100644 --- a/samza-core/src/main/java/org/apache/samza/runtime/LocalContainerRunner.java +++ b/samza-core/src/main/java/org/apache/samza/runtime/LocalContainerRunner.java @@ -105,7 +105,7 @@ public class LocalContainerRunner extends AbstractApplicationRunner { }); String containerId = System.getenv(ShellCommandConfig.ENV_CONTAINER_ID()); - log.info(String.format("Got container ID: %d", containerId)); + log.info(String.format("Got container ID: %s", containerId)); String coordinatorUrl = System.getenv(ShellCommandConfig.ENV_COORDINATOR_URL()); log.info(String.format("Got coordinator URL: %s", coordinatorUrl)); int delay = new Random().nextInt(SamzaContainer.DEFAULT_READ_JOBMODEL_DELAY_MS()) + 1; @@ -127,7 +127,7 @@ public class LocalContainerRunner extends AbstractApplicationRunner { /* package private */ static void setExceptionHandler(Runnable runnable) { Thread.UncaughtExceptionHandler exceptionHandler = (t, e) -> { - log.error(String.format("Uncaught exception in thread (name=%s).", t.getName(), e)); + log.error(String.format("Uncaught exception in thread (name=%s).", t.getName()), e); e.printStackTrace(System.err); runnable.run(); };
