You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by uc...@apache.org on 2015/04/10 15:46:29 UTC
flink git commit: [runtime] [tests] Remove RemoteInputChannelTest
timeout
Repository: flink
Updated Branches:
refs/heads/master 9cd38f0be -> 830dab256
[runtime] [tests] Remove RemoteInputChannelTest timeout
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/830dab25
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/830dab25
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/830dab25
Branch: refs/heads/master
Commit: 830dab256f1428d0e02fbc9ee55a17fdf8f0ec98
Parents: 9cd38f0
Author: Ufuk Celebi <uc...@apache.org>
Authored: Fri Apr 10 15:46:09 2015 +0200
Committer: Ufuk Celebi <uc...@apache.org>
Committed: Fri Apr 10 15:46:09 2015 +0200
----------------------------------------------------------------------
.../io/network/partition/consumer/RemoteInputChannelTest.java | 6 +-----
1 file changed, 1 insertion(+), 5 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/830dab25/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannelTest.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannelTest.java b/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannelTest.java
index 7eb728c..76fae5b 100644
--- a/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannelTest.java
+++ b/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannelTest.java
@@ -21,13 +21,10 @@ package org.apache.flink.runtime.io.network.partition.consumer;
import com.google.common.collect.Lists;
import org.apache.flink.runtime.io.network.ConnectionID;
import org.apache.flink.runtime.io.network.ConnectionManager;
-import org.apache.flink.runtime.io.network.buffer.Buffer;
import org.apache.flink.runtime.io.network.netty.PartitionRequestClient;
import org.apache.flink.runtime.io.network.partition.ResultPartitionID;
import org.apache.flink.runtime.io.network.util.TestBufferFactory;
-import org.apache.flink.runtime.io.network.util.TestPooledBufferProvider;
import org.junit.Test;
-import org.mockito.Matchers;
import java.io.IOException;
import java.util.List;
@@ -37,7 +34,6 @@ import java.util.concurrent.Executors;
import java.util.concurrent.Future;
import static org.junit.Assert.assertEquals;
-import static org.junit.Assert.assertNull;
import static org.junit.Assert.fail;
import static org.mockito.Matchers.any;
import static org.mockito.Matchers.eq;
@@ -73,7 +69,7 @@ public class RemoteInputChannelTest {
verify(inputGate, times(2)).onAvailableBuffer(eq(inputChannel));
}
- @Test(timeout = 120 * 1000)
+ @Test
public void testConcurrentOnBufferAndRelease() throws Exception {
// Config
// Repeatedly spawn two tasks: one to queue buffers and the other to release the channel