kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject kafka git commit: 2198
Date Fri, 02 Dec 2016 18:02:53 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 128d0ff91 -> 93804d50f


2198

Author: Eno Thereska <eno.thereska@gmail.com>

Reviewers: Guozhang Wang <wangguoz@gmail.com>

Closes #2198 from enothereska/hotfix-stream-states


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/93804d50
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/93804d50
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/93804d50

Branch: refs/heads/trunk
Commit: 93804d50ffc40fb6cdc61c073f4a62f0931f042d
Parents: 128d0ff
Author: Eno Thereska <eno.thereska@gmail.com>
Authored: Fri Dec 2 10:02:50 2016 -0800
Committer: Guozhang Wang <wangguoz@gmail.com>
Committed: Fri Dec 2 10:02:50 2016 -0800

----------------------------------------------------------------------
 .../kafka/streams/processor/internals/StreamThread.java      | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/93804d50/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
----------------------------------------------------------------------
diff --git a/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
b/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
index 0c42521..5e82829 100644
--- a/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
+++ b/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
@@ -96,16 +96,16 @@ public class StreamThread extends Thread {
      *          |     |Assigning         |      |  |
      *          |     |Partitions        |------+  |
      *          |     +-----+------------+         |
-     *          |                                  |
-     *          |                                  |
-     *          |    +-----+----------+            |
+     *          |           |                      |
+     *          |           |                      |
+     *          |    +------v---------+            |
      *          +--->|Pending         |------------+
      *               |Shutdown        |
      *               +-----+----------+
      *
      */
     public enum State {
-        NOT_RUNNING(1), RUNNING(1, 2, 4), PARTITIONS_REVOKED(3, 4), ASSIGNING_PARTITIONS(1),
PENDING_SHUTDOWN(0);
+        NOT_RUNNING(1), RUNNING(1, 2, 4), PARTITIONS_REVOKED(3, 4), ASSIGNING_PARTITIONS(1,
4), PENDING_SHUTDOWN(0);
 
         private final Set<Integer> validTransitions = new HashSet<>();
 


Mime
View raw message