[FLINK-8073][kafka-tests] Disable timeout in tests To get stacktraces in case of deadlock do not timeout tests programatically.
This closes #5718. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e273d5fe Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/e273d5fe Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/e273d5fe Branch: refs/heads/master Commit: e273d5fea782399c6887fe7bdc169602a7026fcc Parents: e0bc37b Author: Piotr Nowojski <[email protected]> Authored: Mon Mar 19 09:48:15 2018 +0100 Committer: zentol <[email protected]> Committed: Wed Mar 21 21:01:51 2018 +0100 ---------------------------------------------------------------------- .../connectors/kafka/FlinkKafkaProducer011ITCase.java | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/e273d5fe/flink-connectors/flink-connector-kafka-0.11/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011ITCase.java ---------------------------------------------------------------------- diff --git a/flink-connectors/flink-connector-kafka-0.11/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011ITCase.java b/flink-connectors/flink-connector-kafka-0.11/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011ITCase.java index 81bf0bf..361f269 100644 --- a/flink-connectors/flink-connector-kafka-0.11/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011ITCase.java +++ b/flink-connectors/flink-connector-kafka-0.11/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011ITCase.java @@ -80,7 +80,7 @@ public class FlinkKafkaProducer011ITCase extends KafkaTestBase { * This test ensures that transactions reusing transactional.ids (after returning to the pool) will not clash * with previous transactions using same transactional.ids. */ - @Test(timeout = 120_000L) + @Test public void testRestoreToCheckpointAfterExceedingProducersPool() throws Exception { String topic = "flink-kafka-producer-fail-before-notify"; @@ -123,7 +123,7 @@ public class FlinkKafkaProducer011ITCase extends KafkaTestBase { } } - @Test(timeout = 120_000L) + @Test public void testFlinkKafkaProducer011FailBeforeNotify() throws Exception { String topic = "flink-kafka-producer-fail-before-notify"; @@ -166,7 +166,7 @@ public class FlinkKafkaProducer011ITCase extends KafkaTestBase { deleteTestTopic(topic); } - @Test(timeout = 120_000L) + @Test public void testFlinkKafkaProducer011FailTransactionCoordinatorBeforeNotify() throws Exception { String topic = "flink-kafka-producer-fail-transaction-coordinator-before-notify"; @@ -221,7 +221,7 @@ public class FlinkKafkaProducer011ITCase extends KafkaTestBase { * If such transactions were left alone lingering it consumers would be unable to read committed records * that were created after this lingering transaction. */ - @Test(timeout = 120_000L) + @Test public void testFailBeforeNotifyAndResumeWorkAfterwards() throws Exception { String topic = "flink-kafka-producer-fail-before-notify"; @@ -263,7 +263,7 @@ public class FlinkKafkaProducer011ITCase extends KafkaTestBase { deleteTestTopic(topic); } - @Test(timeout = 120_000L) + @Test public void testFailAndRecoverSameCheckpointTwice() throws Exception { String topic = "flink-kafka-producer-fail-and-recover-same-checkpoint-twice"; @@ -316,7 +316,7 @@ public class FlinkKafkaProducer011ITCase extends KafkaTestBase { * If such transactions were left alone lingering it consumers would be unable to read committed records * that were created after this lingering transaction. */ - @Test(timeout = 120_000L) + @Test public void testScaleDownBeforeFirstCheckpoint() throws Exception { String topic = "scale-down-before-first-checkpoint"; @@ -381,7 +381,7 @@ public class FlinkKafkaProducer011ITCase extends KafkaTestBase { * new subtask have to generate new id(s), but he can not use ids that are potentially in use, so it has to generate * new ones that are greater then 4. */ - @Test(timeout = 120_000L) + @Test public void testScaleUpAfterScalingDown() throws Exception { String topic = "scale-down-before-first-checkpoint";
