Fix Ci failure.

lvyanquan · lvyanquan · commit 5312e42862ae · 2025-10-30T12:02:40.000+08:00
diff --git a/flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/reader/SourceReaderBase.java b/flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/reader/SourceReaderBase.java
@@ -164,6 +164,7 @@ public SourceReaderBase(
                 isRateLimited
                         ? rateLimiterStrategy.createRateLimiter(context.currentParallelism())
                         : null;
+        rateLimitPermissionFuture = CompletableFuture.completedFuture(null);
     }
 
     @Override

Original file line number	Diff line number	Diff line change
`@@ -164,6 +164,7 @@ public SourceReaderBase(`
`164`	`164`	`isRateLimited`
`165`	`165`	`? rateLimiterStrategy.createRateLimiter(context.currentParallelism())`
`166`	`166`	`: null;`
	`167`	`+ rateLimitPermissionFuture = CompletableFuture.completedFuture(null);`
`167`	`168`	`}`
`168`	`169`
`169`	`170`	`@Override`