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 {