tmp

risingwavelabs · May 6, 2024 · 414b264 · 414b264
1 parent d538163
commit 414b264
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 3 deletions.
diff --git a/...ctor-service/src/main/java/com/risingwave/connector/source/common/DbzConnectorConfig.java b/...ctor-service/src/main/java/com/risingwave/connector/source/common/DbzConnectorConfig.java
@@ -124,7 +124,8 @@ public DbzConnectorConfig(
                 null != userProps.get(SNAPSHOT_MODE_KEY)
                         && userProps.get(SNAPSHOT_MODE_KEY).equals(SNAPSHOT_MODE_BACKFILL);
         var waitStreamingStartTimeout =
-                Integer.parseInt(userProps.get(WAIT_FOR_STREAMING_START_TIMEOUT_SECS));
+                Integer.parseInt(
+                        userProps.getOrDefault(WAIT_FOR_STREAMING_START_TIMEOUT_SECS, "30"));
 
         LOG.info(
                 "DbzConnectorConfig: source={}, sourceId={}, startOffset={}, snapshotDone={}, isCdcBackfill={}, isCdcSourceJob={}",

diff --git a/...isingwave-source-test/src/test/java/com/risingwave/connector/source/SourceTestClient.java b/...isingwave-source-test/src/test/java/com/risingwave/connector/source/SourceTestClient.java
@@ -119,7 +119,6 @@ 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);
     }
@@ -144,7 +143,6 @@ 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 {