MINOR: Remove code duplication + excessive space
Reviewers: Guozhang Wang
@@ -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();
}
}
