This is an automated email from the ASF dual-hosted git repository. rhauch pushed a commit to branch 2.6 in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/2.6 by this push: new 93e7a3e KAFKA-10192: Increase max time to wait for worker to start in some integration tests (#10118) 93e7a3e is described below commit 93e7a3e4a3dd21068092f6b8085c38877836e3c7 Author: Luke Chen <43372967+show...@users.noreply.github.com> AuthorDate: Wed Mar 10 01:03:41 2021 +0800 KAFKA-10192: Increase max time to wait for worker to start in some integration tests (#10118) Author: Luke Chen <show...@gmail.com> Reviewers: Chris Egerton <chr...@confluent.io>, Randall Hauch <rha...@gmail.com> --- .../org/apache/kafka/connect/integration/BlockingConnectorTest.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/connect/runtime/src/test/java/org/apache/kafka/connect/integration/BlockingConnectorTest.java b/connect/runtime/src/test/java/org/apache/kafka/connect/integration/BlockingConnectorTest.java index abc9a93..8268de2 100644 --- a/connect/runtime/src/test/java/org/apache/kafka/connect/integration/BlockingConnectorTest.java +++ b/connect/runtime/src/test/java/org/apache/kafka/connect/integration/BlockingConnectorTest.java @@ -77,7 +77,7 @@ public class BlockingConnectorTest { private static final String NORMAL_CONNECTOR_NAME = "normal-connector"; private static final String TEST_TOPIC = "normal-topic"; private static final int NUM_RECORDS_PRODUCED = 100; - private static final long CONNECT_WORKER_STARTUP_TIMEOUT = TimeUnit.SECONDS.toMillis(30); + private static final long CONNECT_WORKER_STARTUP_TIMEOUT = TimeUnit.SECONDS.toMillis(60); private static final long RECORD_TRANSFER_DURATION_MS = TimeUnit.SECONDS.toMillis(30); private static final long REST_REQUEST_TIMEOUT = Worker.CONNECTOR_GRACEFUL_SHUTDOWN_TIMEOUT_MS * 2;