Details
-
Technical Debt
-
Status: Open
-
Major
-
Resolution: Unresolved
-
None
-
None
-
None
Description
This ticket should only contain items where SourceFunction is already used in the existing code base. For new functionality and Source V2 API improvements, use FLINK-32692.
—
Current state of migration to Source V2 API for officially-supported connectors
FileSystem (Public)
Kafka (PublicEvolving)
Cassandra (PublicEvolving)
Pulsar (PublicEvolving)
HiveSource (PublicEvolving)
HybridSource (PublicEvolving)
MongoDB (PublicEvolving)
Hive (PublicEvolving)
Kinesis (Experimental)
JDBC - not impacted (based on TableFunction)
HBase - not impacted (based on TableFunction)
RabbitMQ
Google Pub Sub
Links to externalized connector repos: https://cwiki.apache.org/confluence/display/FLINK/Externalized+Connector+development
Attachments
Issue Links
- is a parent of
-
FLINK-28061 create new tech blog for connector development based on Source API
-
- Open
-
- is duplicated by
-
-
- Closed
-
- mentioned in
-
Page Loading...
1.
|
Migrate ParallelSourceFunction classes to Source V2 API or prepare for removal |
|
Open | Alexander Fedulov |
2.
|
Promote ExternallyInducedSourceReader to non-experimental @Public |
|
Open | Unassigned |
3.
|
Migrate RabbitMQ connector to Source V2 API |
|
Open | Unassigned |
4.
|
Migrage Google PubSub connector to V2 |
|
Open | Unassigned |
5.
|
Promote Kinesis connector support to PublicEvolving |
|
Open | Unassigned |
6.
|
Migrate SourceFunction in Tests to Source V2 API |
|
Open | Alexander Fedulov |
7.
|
Remove usage of FromElementsFunction |
|
Open | Alexander Fedulov |
8.
|
Migrate LoadSimulationPipeline in Flink K8S Operator to the new Source API |
|
Open | Unassigned |