[flink] 09/14: [hotfix] [tests] Remove unnecessary timeouts from SingleInputGate Tests

[se...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

sewen pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git

commit e94ec4feafd15ee0562ae1f711f2f19b3d3d85f6
Author: Stephan Ewen <se...@apache.org>
AuthorDate: Fri May 10 13:50:26 2019 +0200

    [hotfix] [tests] Remove unnecessary timeouts from SingleInputGate Tests
    
    These tests very lightweight and no longer run with any concurrency or external interaction
    and hence do not require any timeouts.
---
 .../runtime/io/network/partition/consumer/SingleInputGateTest.java    | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/consumer/SingleInputGateTest.java b/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/consumer/SingleInputGateTest.java
index 5dda8db..07fcd26 100644
--- a/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/consumer/SingleInputGateTest.java
+++ b/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/consumer/SingleInputGateTest.java
@@ -80,7 +80,7 @@ public class SingleInputGateTest extends InputGateTestBase {
 	 * Tests basic correctness of buffer-or-event interleaving and correct <code>null</code> return
 	 * value after receiving all end-of-partition events.
 	 */
-	@Test(timeout = 120 * 1000)
+	@Test
 	public void testBasicGetNextLogic() throws Exception {
 		// Setup
 		final SingleInputGate inputGate = createInputGate();
@@ -129,7 +129,7 @@ public class SingleInputGateTest extends InputGateTestBase {
 		testIsAvailable(inputGate, inputGate, inputChannel);
 	}
 
-	@Test(timeout = 120 * 1000)
+	@Test
 	public void testIsMoreAvailableReadingFromSingleInputChannel() throws Exception {
 		// Setup
 		final SingleInputGate inputGate = createInputGate();