add log

Signed-off-by: Pei Yu <125331682@qq.com>

Author: sd4324530

flink-cdc-flink1-compat/src/main/java/org/apache/flink/connector/base/source/reader/SingleThreadMultiplexSourceReaderBaseAdapter.java

@@ -6,19 +6,29 @@
 import org.apache.flink.configuration.Configuration;
 import org.apache.flink.connector.base.source.reader.fetcher.SingleThreadFetcherManager;
 
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
 import javax.annotation.Nullable;
 
 public abstract class SingleThreadMultiplexSourceReaderBaseAdapter<
                 E, T, SplitT extends SourceSplit, SplitStateT>
         extends SingleThreadMultiplexSourceReaderBase<E, T, SplitT, SplitStateT> {
 
+    private static final Logger LOG =
+            LoggerFactory.getLogger(SingleThreadMultiplexSourceReaderBaseAdapter.class);
+
     public SingleThreadMultiplexSourceReaderBaseAdapter(
             SingleThreadFetcherManager<E, SplitT> splitFetcherManager,
             RecordEmitter<E, T, SplitStateT> recordEmitter,
             @Nullable RecordEvaluator<T> eofRecordEvaluator,
             Configuration config,
             SourceReaderContext context,
-            RateLimiterStrategy rateLimiterStrategy) {
+            @Nullable RateLimiterStrategy rateLimiterStrategy) {
         super(splitFetcherManager, recordEmitter, eofRecordEvaluator, config, context);
+        if (null != rateLimiterStrategy) {
+            LOG.warn(
+                    "Because the runtime environment is Flink 1.x, the connector options `records.per.second` is ignored.");
+        }
     }
 }