Details
-
Bug
-
Status: Closed
-
Blocker
-
Resolution: Fixed
-
1.19.0
-
None
Description
The sink API compatibility was broken in FLINK-25857.
org.apache.flink.api.connector.sink2.Sink#createWriter(InitContext) was changed to org.apache.flink.api.connector.sink2.Sink#createWriter(WriterInitContext).
All external connectors sink can not compile as this change.
For example:
es: https://github.com/apache/flink-connector-elasticsearch/actions/runs/6976181890/job/18984287421
aws: https://github.com/apache/flink-connector-aws/actions/runs/6975253086/job/18982104160
Attachments
Issue Links
- is caused by
-
FLINK-25857 Add committer metrics to track the status of committables
- Resolved