You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by cr...@apache.org on 2014/07/10 23:51:23 UTC

git commit: SAMZA-324; make a better toString for SSPs

Repository: incubator-samza
Updated Branches:
  refs/heads/master 46bc23b92 -> fd5ee548a


SAMZA-324; make a better toString for SSPs


Project: http://git-wip-us.apache.org/repos/asf/incubator-samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-samza/commit/fd5ee548
Tree: http://git-wip-us.apache.org/repos/asf/incubator-samza/tree/fd5ee548
Diff: http://git-wip-us.apache.org/repos/asf/incubator-samza/diff/fd5ee548

Branch: refs/heads/master
Commit: fd5ee548a1966b6679212cd1a09a2d8ec60acdda
Parents: 46bc23b
Author: Naveen <na...@gmail.com>
Authored: Thu Jul 10 14:51:16 2014 -0700
Committer: Chris Riccomini <cr...@criccomi-mn.linkedin.biz>
Committed: Thu Jul 10 14:51:16 2014 -0700

----------------------------------------------------------------------
 .../main/java/org/apache/samza/system/SystemStreamPartition.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-samza/blob/fd5ee548/samza-api/src/main/java/org/apache/samza/system/SystemStreamPartition.java
----------------------------------------------------------------------
diff --git a/samza-api/src/main/java/org/apache/samza/system/SystemStreamPartition.java b/samza-api/src/main/java/org/apache/samza/system/SystemStreamPartition.java
index bb69c38..4fed4dc 100644
--- a/samza-api/src/main/java/org/apache/samza/system/SystemStreamPartition.java
+++ b/samza-api/src/main/java/org/apache/samza/system/SystemStreamPartition.java
@@ -96,6 +96,6 @@ public class SystemStreamPartition extends SystemStream {
 
   @Override
   public String toString() {
-    return "SystemStreamPartition [partition=" + partition + ", system=" + system + ", stream=" + stream + "]";
+    return "SystemStreamPartition ["+ system + ", " + stream + ", " + partition.getPartitionId() + "]";
   }
 }