[kafka] branch trunk updated: MINOR: Remove unnecessary statement from WorkerConnector#doRun (#9653)

[ch...@apache.org]

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

chia7712 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 5200eaa  MINOR: Remove unnecessary statement from WorkerConnector#doRun (#9653)
5200eaa is described below

commit 5200eaab258637f99966d9920812e1fa3fd36b35
Author: abc863377 <ab...@yahoo.com.tw>
AuthorDate: Wed Nov 25 22:48:02 2020 +0800

    MINOR: Remove unnecessary statement from WorkerConnector#doRun (#9653)
    
    Reviewers: Chia-Ping Tsai <ch...@gmail.com>
---
 .../src/main/java/org/apache/kafka/connect/runtime/WorkerConnector.java  | 1 -
 1 file changed, 1 deletion(-)

diff --git a/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerConnector.java b/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerConnector.java
index b65931e..7cfb4f4 100644
--- a/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerConnector.java
+++ b/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerConnector.java
@@ -143,7 +143,6 @@ public class WorkerConnector implements Runnable {
                 if (pendingTargetStateChange.get() != null || stopping) {
                     // An update occurred before we entered the synchronized block; no big deal,
                     // just start the loop again until we've handled everything
-                    continue;
                 } else {
                     try {
                         wait();