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;
 

Reply via email to