From d5381635e3db428e74a228983aa3edad46d73a47 Mon Sep 17 00:00:00 2001
From: Kexiang Wang <kx.wang@hotmail.com>
Date: Mon, 6 May 2024 15:52:51 -0400
Subject: [PATCH] tmp

---
 .../java/com/risingwave/connector/source/SourceTestClient.java  | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/java/connector-node/risingwave-source-test/src/test/java/com/risingwave/connector/source/SourceTestClient.java b/java/connector-node/risingwave-source-test/src/test/java/com/risingwave/connector/source/SourceTestClient.java
index 58c72c688dfef..e8be33e90ee3c 100644
--- a/java/connector-node/risingwave-source-test/src/test/java/com/risingwave/connector/source/SourceTestClient.java
+++ b/java/connector-node/risingwave-source-test/src/test/java/com/risingwave/connector/source/SourceTestClient.java
@@ -119,6 +119,7 @@ protected ConnectorServiceProto.ValidateSourceResponse validateSource(
                         .putProperties("server.id", "1") // mysql only
                         .putProperties("publication.name", "rw_publication") // pg only
                         .putProperties("publication.create.enable", "true") // pg only
+                        .putProperties("cdc.source.wait.streaming.start.timeout", "30")
                         .build();
         return blockingStub.validateSource(req);
     }
@@ -143,6 +144,7 @@ protected Iterator<ConnectorServiceProto.GetEventStreamResponse> getEventStreamS
                         .putProperties("schema.name", "public") // pg only
                         .putProperties("slot.name", "orders") // pg only
                         .putProperties("server.id", "1") // mysql only
+                        .putProperties("cdc.source.wait.streaming.start.timeout", "30")
                         .build();
         Iterator<ConnectorServiceProto.GetEventStreamResponse> responses = null;
         try {