This is an automated email from the ASF dual-hosted git repository. aljoscha pushed a commit to branch release-1.11 in repository https://gitbox.apache.org/repos/asf/flink.git
commit 31c3a15731e91d01fb033fe5a8f8173e3ba0cb38 Author: Aljoscha Krettek <[email protected]> AuthorDate: Thu Jun 4 10:33:24 2020 +0200 [FLINK-17260] Increase timeout for reading Kafka messages in StreamingKafkaITCase --- .../org/apache/flink/tests/util/kafka/LocalStandaloneKafkaResource.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/main/java/org/apache/flink/tests/util/kafka/LocalStandaloneKafkaResource.java b/flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/main/java/org/apache/flink/tests/util/kafka/LocalStandaloneKafkaResource.java index a651d12..5dc1137 100644 --- a/flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/main/java/org/apache/flink/tests/util/kafka/LocalStandaloneKafkaResource.java +++ b/flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/main/java/org/apache/flink/tests/util/kafka/LocalStandaloneKafkaResource.java @@ -278,7 +278,7 @@ public class LocalStandaloneKafkaResource implements KafkaResource { .setStdoutProcessor(messages::add) .runNonBlocking()) { - final Deadline deadline = Deadline.fromNow(Duration.ofSeconds(30)); + final Deadline deadline = Deadline.fromNow(Duration.ofSeconds(120)); while (deadline.hasTimeLeft() && messages.size() < expectedNumMessages) { try { LOG.info("Waiting for messages. Received {}/{}.", messages.size(),
