You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by bo...@apache.org on 2018/08/23 00:51:29 UTC
samza git commit: String format params fix.
Repository: samza
Updated Branches:
refs/heads/master a9ff09373 -> fc7a4dce7
String format params fix.
Author: Boris S <bo...@apache.org>
Author: Boris Shkolnik <bs...@linkedin.com>
Reviewers: Bharath Kumarasubramanian <co...@gmail.com>, Prateek Maheshwari <pm...@apache.org>
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 <bo...@apache.org>
Authored: Wed Aug 22 17:51:16 2018 -0700
Committer: Boris S <bo...@apache.org>
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));
}