You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by al...@apache.org on 2020/06/05 13:34:57 UTC
[flink] 02/05: [FLINK-17260] Increase timeout for reading Kafka
messages in StreamingKafkaITCase
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 <al...@apache.org>
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(),