From 3acbbdb018b60f48181e9dbf8909cfcf8ee0d6db Mon Sep 17 00:00:00 2001
From: abc863377 <abc863377@yahoo.com.tw>
Date: Wed, 25 Nov 2020 19:04:59 +0800
Subject: [PATCH] MINOR: Remove Unnecessary statement from WorkerConnector

---
 .../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 b65931e0a4b19..7cfb4f434b90d 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 @@ void doRun() {
                 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();