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:34:53 UTC
[kafka] branch 2.8 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.8
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/2.8 by this push:
new e849e60 KAFKA-10192: Increase max time to wait for worker to start in some integration tests (#10118)
e849e60 is described below
commit e849e603373a1e94926e3897c1882f8515a05e00
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;