You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Hongshun Wang (Jira)" <ji...@apache.org> on 2024/01/22 12:02:00 UTC
[jira] [Created] (FLINK-34196) FLIP-389 Annotate SingleThreadFetcherManager as PublicEvolving.
Hongshun Wang created FLINK-34196:
-------------------------------------
Summary: FLIP-389 Annotate SingleThreadFetcherManager as PublicEvolving.
Key: FLINK-34196
URL: https://issues.apache.org/jira/browse/FLINK-34196
Project: Flink
Issue Type: Improvement
Components: Connectors / Common
Affects Versions: 1.18.1
Reporter: Hongshun Wang
Fix For: 1.19.0
This improvement implements [FLIP-389](|https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=278465498]
This flip has 2 goals:
* To expose the SplitFetcherManager / SingleThreadFetcheManager as Public, allowing connector developers to easily create their own threading models in the SourceReaderBase.
* To hide the element queue from the connector developers and make SplitFetcherManager the only owner class of the queue
--
This message was sent by Atlassian Jira
(v8.20.10#820010)