You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by sn...@apache.org on 2023/12/21 10:01:31 UTC
(flink) branch master updated: [FLINK-33877][streaming] Adjust `CollectSinkFunctionTest#testConfiguredPortIsUsed` assertion message to work with JDK 21
This is an automated email from the ASF dual-hosted git repository.
snuyanzin pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new 13454fd245b [FLINK-33877][streaming] Adjust `CollectSinkFunctionTest#testConfiguredPortIsUsed` assertion message to work with JDK 21
13454fd245b is described below
commit 13454fd245bc02d73632da51d90cc33c38aaaa0c
Author: Jiabao Sun <ji...@xtransfer.cn>
AuthorDate: Thu Dec 21 18:01:23 2023 +0800
[FLINK-33877][streaming] Adjust `CollectSinkFunctionTest#testConfiguredPortIsUsed` assertion message to work with JDK 21
---
.../streaming/api/operators/collect/CollectSinkFunctionTest.java | 6 ++----
1 file changed, 2 insertions(+), 4 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 f3a08a15df4..8bba86e0a8a 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
@@ -20,7 +20,6 @@ package org.apache.flink.streaming.api.operators.collect;
import org.apache.flink.api.common.typeutils.TypeSerializer;
import org.apache.flink.api.common.typeutils.base.IntSerializer;
import org.apache.flink.configuration.TaskManagerOptions;
-import org.apache.flink.core.testutils.FlinkAssertions;
import org.apache.flink.streaming.api.operators.collect.utils.CollectSinkFunctionTestWrapper;
import org.apache.flink.streaming.api.operators.collect.utils.CollectTestUtils;
import org.apache.flink.util.TestLogger;
@@ -136,9 +135,8 @@ public class CollectSinkFunctionTest extends TestLogger {
.getConfiguration()
.setInteger(TaskManagerOptions.COLLECT_PORT, socket.getLocalPort());
assertThatThrownBy(() -> functionWrapper.openFunction())
- .satisfies(
- FlinkAssertions.anyCauseMatches(
- BindException.class, "Address already in use (Bind failed)"));
+ .isInstanceOf(BindException.class)
+ .hasMessageContaining("Address already in use");
}
}