You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by zh...@apache.org on 2020/08/12 08:29:09 UTC
[flink] 01/02: [hotfix][tests] Unignore
PartitionRequestClientFactoryTest class
This is an automated email from the ASF dual-hosted git repository.
zhijiang pushed a commit to branch release-1.11
in repository https://gitbox.apache.org/repos/asf/flink.git
commit a86c430afee10d4f5445d3693bc0f1c83e863aa0
Author: Roman Khachatryan <kh...@gmail.com>
AuthorDate: Mon Aug 10 15:41:23 2020 +0200
[hotfix][tests] Unignore PartitionRequestClientFactoryTest class
---
.../runtime/io/network/netty/PartitionRequestClientFactoryTest.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/netty/PartitionRequestClientFactoryTest.java b/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/netty/PartitionRequestClientFactoryTest.java
index d971634..e2bcc23 100644
--- a/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/netty/PartitionRequestClientFactoryTest.java
+++ b/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/netty/PartitionRequestClientFactoryTest.java
@@ -45,12 +45,12 @@ import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertTrue;
import static org.junit.Assert.fail;
-@Ignore
public class PartitionRequestClientFactoryTest {
private final static int SERVER_PORT = NetUtils.getAvailablePort();
@Test
+ @Ignore
public void testResourceReleaseAfterInterruptedConnect() throws Exception {
// Latch to synchronize on the connect call.