You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ti...@apache.org on 2023/04/25 00:30:53 UTC
[flink-connector-pulsar] branch main updated: [FLINK-31748] Dummy implementation to fix compilation failure (#43)
This is an automated email from the ASF dual-hosted git repository.
tison pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/flink-connector-pulsar.git
The following commit(s) were added to refs/heads/main by this push:
new bbb636a [FLINK-31748] Dummy implementation to fix compilation failure (#43)
bbb636a is described below
commit bbb636a433ded42f61b1e54811d046b590c4d514
Author: tison <wa...@gmail.com>
AuthorDate: Tue Apr 25 08:30:48 2023 +0800
[FLINK-31748] Dummy implementation to fix compilation failure (#43)
Signed-off-by: tison <wa...@gmail.com>
---
.../connector/pulsar/source/reader/PulsarSourceFetcherManager.java | 7 ++++++-
1 file changed, 6 insertions(+), 1 deletion(-)
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 @@ 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 class PulsarSourceFetcherManager
}
}
+ // @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) {