[
https://issues.apache.org/jira/browse/FLINK-37687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17947955#comment-17947955
]
Mohsen Rezaei commented on FLINK-37687:
---------------------------------------
An example for the {{KinesisStreamsSink}}:
{code}
java.lang.AbstractMethodError: Receiver class
org.apache.flink.connector.kinesis.sink.KinesisStreamsSink does not define or
inherit an implementation of the resolved method 'abstract
org.apache.flink.api.connector.sink2.SinkWriter
createWriter(org.apache.flink.api.connector.sink2.WriterInitContext)' of
interface org.apache.flink.api.connector.sink2.Sink.
at
org.apache.flink.streaming.runtime.operators.sink.StatefulSinkWriterStateHandler.createWriter(StatefulSinkWriterStateHandler.java:122)
at
org.apache.flink.streaming.runtime.operators.sink.SinkWriterOperator.initializeState(SinkWriterOperator.java:181)
at
org.apache.flink.streaming.api.operators.StreamOperatorStateHandler.initializeOperatorState(StreamOperatorStateHandler.java:142)
at
org.apache.flink.streaming.api.operators.AbstractStreamOperator.initializeState(AbstractStreamOperator.java:304)
at
org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.initializeStateAndOpenOperators(RegularOperatorChain.java:106)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.restoreStateAndGates(StreamTask.java:857)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.lambda$restoreInternal$5(StreamTask.java:811)
at
org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.call(StreamTaskActionExecutor.java:55)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.restoreInternal(StreamTask.java:811)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.restore(StreamTask.java:770)
at
org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:963)
at
org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:932)
at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:756)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:568)
at java.base/java.lang.Thread.run(Unknown Source)
{code}
The {{AsyncSinkBase}} internal implementation was deprecated in Flink
{{1.19.0}}, and upgraded in Flink 2, making it incompatible with the Flink
{{2.0.0}} release.
> Bump flink-connector-aws to 2.0
> -------------------------------
>
> Key: FLINK-37687
> URL: https://issues.apache.org/jira/browse/FLINK-37687
> Project: Flink
> Issue Type: Bug
> Components: Connectors / AWS, Connectors / DynamoDB, Connectors /
> Firehose, Connectors / Kinesis
> Affects Versions: 2.0.0
> Reporter: Keith Lee
> Priority: Major
>
> Flink 2.0 has breaking changes on interfaces that connectors implement e.g.
> Sink
> ```
> Error:
> /home/runner/work/flink-connector-aws/flink-connector-aws/flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/DynamoDbBeanElementConverter.java:[67,26]
> cannot find symbol
> Error: symbol: class InitContext
> Error: location: interface org.apache.flink.api.connector.sink2.Sink
> Error:
> /home/runner/work/flink-connector-aws/flink-connector-aws/flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/DynamoDbSinkWriter.java:[160,5]
> method does not override or implement a method from a supertype
> ```
> 1. We need to discuss strategy on maintaining branches for 1.20 LTS and also
> 2.x
> 2. We need to work on migrating current sources/sinks to 2.x on 2.x branch
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
