[FLINK-2652] [tests] Temporary ignore flakey PartitionRequestClientFactoryTest
Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b2339464 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b2339464 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/b2339464 Branch: refs/heads/master Commit: b23394640c8b4f8751c16f7c7dee5bc33de91bbd Parents: 5671c77 Author: Ufuk Celebi <[email protected]> Authored: Sun Sep 20 13:08:24 2015 +0200 Committer: Till Rohrmann <[email protected]> Committed: Tue Oct 20 00:16:51 2015 +0200 ---------------------------------------------------------------------- .../io/network/netty/PartitionRequestClientFactoryTest.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/b2339464/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/netty/PartitionRequestClientFactoryTest.java ---------------------------------------------------------------------- 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 24a2a5c..56e5bde 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 @@ -25,6 +25,8 @@ import io.netty.channel.ChannelPromise; import org.apache.flink.api.java.tuple.Tuple2; import org.apache.flink.configuration.Configuration; import org.apache.flink.runtime.io.network.ConnectionID; +import org.apache.flink.runtime.net.NetUtils; +import org.junit.Ignore; import org.junit.Test; import java.io.IOException; @@ -41,9 +43,10 @@ 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 = 10021; + private final static int SERVER_PORT = NetUtils.getAvailablePort(); @Test public void testResourceReleaseAfterInterruptedConnect() throws Exception {
