[FLINK-31748] Dummy implementation to fix compilation failure (#43)
Signed-off-by: tison <wander4096@gmail.com>
diff --git a/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader/PulsarSourceFetcherManager.java b/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader/PulsarSourceFetcherManager.java
index 7382f29..2680ba7 100644
--- a/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader/PulsarSourceFetcherManager.java
+++ b/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader/PulsarSourceFetcherManager.java
@@ -60,7 +60,7 @@
* 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 @@
}
}
+ // @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) {
