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.