address hang's comment

leonardBang · Jul 20, 2023 · 1e61d69 · 1e61d69
1 parent 49aa591
commit 1e61d69
Showing 1 changed file with 2 additions and 5 deletions.
diff --git a/flink-connector-debezium/src/main/java/com/ververica/cdc/debezium/internal/Handover.java b/flink-connector-debezium/src/main/java/com/ververica/cdc/debezium/internal/Handover.java
@@ -219,11 +219,8 @@ public ClosedException(String message, Throwable cause) {
         }
 
         public static boolean isGentlyClosedException(Throwable cause) {
-            if (cause instanceof ClosedException
-                    && GENTLY_CLOSED_MESSAGE.equals(((ClosedException) cause).getMessage())) {
-                return true;
-            }
-            return false;
+            return cause instanceof ClosedException
+                    && GENTLY_CLOSED_MESSAGE.equals(((ClosedException) cause).getMessage());
         }
     }
 }