You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ji...@apache.org on 2023/12/19 21:11:44 UTC
(flink) 02/02: Remove useless finally block
This is an automated email from the ASF dual-hosted git repository.
jingge pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 7cae20f22a24403210ca5d6addf83571fcf46843
Author: Jiabao Sun <ji...@xtransfer.cn>
AuthorDate: Tue Dec 19 16:25:59 2023 +0800
Remove useless finally block
---
.../flink/streaming/api/operators/collect/CollectSinkFunctionTest.java | 2 --
1 file changed, 2 deletions(-)
diff --git a/flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/collect/CollectSinkFunctionTest.java b/flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/collect/CollectSinkFunctionTest.java
index dd22199e0a8..f3a08a15df4 100644
--- a/flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/collect/CollectSinkFunctionTest.java
+++ b/flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/collect/CollectSinkFunctionTest.java
@@ -139,8 +139,6 @@ public class CollectSinkFunctionTest extends TestLogger {
.satisfies(
FlinkAssertions.anyCauseMatches(
BindException.class, "Address already in use (Bind failed)"));
- } finally {
- functionWrapper.closeWrapper();
}
}