Skip to content

Commit 1e61d69

Browse files
committed
address hang's comment
1 parent 49aa591 commit 1e61d69

File tree

1 file changed

+2
-5
lines changed

1 file changed

+2
-5
lines changed

flink-connector-debezium/src/main/java/com/ververica/cdc/debezium/internal/Handover.java

Lines changed: 2 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -219,11 +219,8 @@ public ClosedException(String message, Throwable cause) {
219219
}
220220

221221
public static boolean isGentlyClosedException(Throwable cause) {
222-
if (cause instanceof ClosedException
223-
&& GENTLY_CLOSED_MESSAGE.equals(((ClosedException) cause).getMessage())) {
224-
return true;
225-
}
226-
return false;
222+
return cause instanceof ClosedException
223+
&& GENTLY_CLOSED_MESSAGE.equals(((ClosedException) cause).getMessage());
227224
}
228225
}
229226
}

0 commit comments

Comments
 (0)