[FLINK-31748] Dummy implementation to fix compilation failure (apache#43

)

Signed-off-by: tison <[email protected]>

flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader/PulsarSourceFetcherManager.java

@@ -60,7 +60,7 @@ public class PulsarSourceFetcherManager
      * Creates a new SplitFetcherManager with multiple I/O threads.
      *
      * @param elementsQueue The queue that is used to hand over data from the I/O thread (the
-     *     fetchers) to the reader (which emits the records and book-keeps the state. This must be
+     *     fetchers) to the reader, which emits the records and book-keeps the state. This must be
      *     the same queue instance that is also passed to the {@link SourceReaderBase}.
      * @param splitReaderSupplier The factory for the split reader that connects to the source
      */
@@ -86,6 +86,11 @@ public void addSplits(List<PulsarPartitionSplit> splitsToAdd) {
         }
     }
 
+    // @Override // to keep compatible with Flink 1.17
+    public void removeSplits(List<PulsarPartitionSplit> splitsToRemove) {
+        // TODO empty - wait for FLINK-31748 to implement it.
+    }
+
     @Override
     protected void startFetcher(SplitFetcher<Message<byte[]>, PulsarPartitionSplit> fetcher) {
         if (fetcherStatus.get(fetcher.fetcherId()) != Boolean.TRUE) {