Yun Tang created FLINK-31324:
--------------------------------
Summary: Broken SingleThreadFetcherManager constructor API
Key: FLINK-31324
URL: https://issues.apache.org/jira/browse/FLINK-31324
Project: Flink
Issue Type: Bug
Components: Connectors / Parent
Reporter: Yun Tang
Assignee: Yun Tang
Fix For: 1.17.0
FLINK-28853 changed the default constructor of {{SingleThreadFetcherManager}}.
Though the {{SingleThreadFetcherManager}} is annotated as {{Internal}}, it
actually acts as some-degree public API, which is widely used in many connector
projects:
[flink-cdc-connector|https://github.com/ververica/flink-cdc-connectors/blob/release-2.3.0/flink-connector-mysql-cdc/src/main/java/com/ververica/cdc/connectors/mysql/source/reader/MySqlSourceReader.java#L93],
[flink-connector-mongodb|https://github.com/apache/flink-connector-mongodb/blob/main/flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/MongoSourceReader.java#L58]
and so on.
Once flink-1.17 is released, all these existing connectors are broken and
cannot be used in new release version. Thus, I suggest to make the original
SingleThreadFetcherManager constructor as depreacted instead of removing it.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
