You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by rh...@apache.org on 2021/03/09 18:36:22 UTC
[kafka] branch 2.7 updated: KAFKA-10192: Increase max time to wait
for worker to start in some integration tests (#10118)
This is an automated email from the ASF dual-hosted git repository.
rhauch pushed a commit to branch 2.7
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/2.7 by this push:
new 5f53f02 KAFKA-10192: Increase max time to wait for worker to start in some integration tests (#10118)
5f53f02 is described below
commit 5f53f02e88780d28644cca2a28105f1fc931eb26
Author: Luke Chen <43...@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 <sh...@gmail.com>
Reviewers: Chris Egerton <ch...@confluent.io>, Randall Hauch <rh...@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;