search

awslabs / amazon-kinesis-connector-flink

This is a fork of the Apache Flink Kinesis connector adding Enhanced Fanout support for Flink 1.8/1.11 on KDA.
Apache License 2.0
21 stars 11 forks source link

Problems encountered when using aws connector to replace flink connector to connect kinesis stream in flink #34

Closed SOD-DOB closed 3 years ago

SOD-DOB commented 3 years ago

Before I used the flink connector to connect the kinesis stream, there would always be such a problem image

The following is my previous pom <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-connector-kinesis_2.12</artifactId> <version>1.11.3</version> </dependency>

When I replace with aws connector <dependency> <groupId>software.amazon.kinesis</groupId> <artifactId>amazon-kinesis-connector-flink</artifactId> <version>2.0.3</version> </dependency>

The following error occurred, but I could not find the related package exception image

Can you help me answer it?

dannycranmer commented 3 years ago

Are you getting this error with a clean Flink job, with no state? Or are you trying to restore from an old checkpoint or savepoint?

dannycranmer commented 3 years ago

Closing due to staleness, please reopen if needed