[kafka] branch trunk updated: MINOR: Remove code duplication + excessive space (#4683)

[guozhang]

This is an automated email from the ASF dual-hosted git repository.

guozhang pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new c28c556  MINOR: Remove code duplication + excessive space (#4683)
c28c556 is described below

commit c28c556e9295b9d499f7b1b0ec65bbb4d1ad4b67
Author: Jacek Laskowski <ja...@japila.pl>
AuthorDate: Sun Mar 11 19:38:03 2018 +0100

    MINOR: Remove code duplication + excessive space (#4683)
    
    Reviewers: Guozhang Wang <wangg...@gmail.com>
---
 .../org/apache/kafka/streams/processor/internals/StreamThread.java  | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

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 cda04e9..e1c45b4 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
@@ -222,7 +222,7 @@ public class StreamThread extends Thread {
 
     public boolean isRunning() {
         synchronized (stateLock) {
-            return state == State.RUNNING || state == State.PARTITIONS_REVOKED 
|| state == State.PARTITIONS_ASSIGNED;
+            return state.isRunning();
         }
     }
 
@@ -394,7 +394,7 @@ public class StreamThread extends Thread {
                   taskCreatedSensor,
                   storeChangelogReader,
                   time,
-                    log);
+                  log);
             this.cache = cache;
             this.clientSupplier = clientSupplier;
             this.threadProducer = threadProducer;
@@ -463,7 +463,7 @@ public class StreamThread extends Thread {
                   taskCreatedSensor,
                   storeChangelogReader,
                   time,
-                    log);
+                  log);
         }
 
         @Override

-- 
To stop receiving notification emails like this one, please contact
guozh...@apache.org.