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 <[email protected]> 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();
