[jira] [Created] (FLINK-36745) Code snippets on the Data Sources page use deprecated (and removed in 2.0) APIs

["Andrei Kaigorodov (Jira)" <ji...@apache.org>]

Andrei Kaigorodov created FLINK-36745:
-----------------------------------------

             Summary: Code snippets on the Data Sources page use deprecated (and removed in 2.0) APIs
                 Key: FLINK-36745
                 URL: https://issues.apache.org/jira/browse/FLINK-36745
             Project: Flink
          Issue Type: Bug
          Components: Connectors / Common, Documentation
    Affects Versions: 1.20.0, 1.20.1
            Reporter: Andrei Kaigorodov


In Flink 2.0, a few deprecated constructors for SplitFetcherManager and SourceReaderBase have been removed by

FLINK-36245 [https://github.com/apache/flink/pull/25331]

more specifically the constructors that let the client code pass the _elementsQueue_ object.

However, the examples on the Data Sources page still use the old API:

[https://nightlies.apache.org/flink/flink-docs-master/docs/dev/datastream/sources/]

see code snippets for FixedSizeSplitFetcherManager and FixedFetcherSizeSourceReader.
{code:java}
    public FixedSizeSplitFetcherManager(
            int numFetchers,
            FutureCompletingBlockingQueue<RecordsWithSplitIds<E>> elementsQueue,
            Supplier<SplitReader<E, SplitT>> splitReaderSupplier) {
        super(elementsQueue, splitReaderSupplier); <- it refers to the removed constructor
{code}
i.e. the examples should be adjusted to match the new API



--
This message was sent by Atlassian Jira
(v8.20.10#820010)