Repository: samza Updated Branches: refs/heads/master a9ff09373 -> fc7a4dce7
String format params fix. Author: Boris S <[email protected]> Author: Boris Shkolnik <[email protected]> Reviewers: Bharath Kumarasubramanian <[email protected]>, Prateek Maheshwari <[email protected]> Closes #613 from sborya/StringFormatParams Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/fc7a4dce Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/fc7a4dce Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/fc7a4dce Branch: refs/heads/master Commit: fc7a4dce767c94ed903b24981e0f135d4f7305a1 Parents: a9ff093 Author: Boris S <[email protected]> Authored: Wed Aug 22 17:51:16 2018 -0700 Committer: Boris S <[email protected]> Committed: Wed Aug 22 17:51:16 2018 -0700 ---------------------------------------------------------------------- .../src/main/java/org/apache/samza/task/TaskCallbackImpl.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/samza/blob/fc7a4dce/samza-core/src/main/java/org/apache/samza/task/TaskCallbackImpl.java ---------------------------------------------------------------------- diff --git a/samza-core/src/main/java/org/apache/samza/task/TaskCallbackImpl.java b/samza-core/src/main/java/org/apache/samza/task/TaskCallbackImpl.java index b09db62..5c178aa 100644 --- a/samza-core/src/main/java/org/apache/samza/task/TaskCallbackImpl.java +++ b/samza-core/src/main/java/org/apache/samza/task/TaskCallbackImpl.java @@ -71,7 +71,7 @@ class TaskCallbackImpl implements TaskCallback, Comparable<TaskCallbackImpl> { if (isComplete.compareAndSet(false, true)) { listener.onComplete(this); } else { - String msg = String.format("Callback complete was invoked after completion for task {}, ssp {}, offset {}.", + String msg = String.format("Callback complete was invoked after completion for task %s, ssp %s, offset %s.", taskName, envelope.getSystemStreamPartition(), envelope.getOffset()); listener.onFailure(this, new IllegalStateException(msg)); }
