flink-cdc icon indicating copy to clipboard operation
flink-cdc copied to clipboard

[Bug] 3.0 StarRocksDataSink不支持 flink1.14 【java.lang.NoClassDefFoundError: org/apache/flink/api/connector/sink2/Sink】

Open cleverUtd opened this issue 1 year ago • 1 comments

Search before asking

  • [X] I searched in the issues and found nothing similar.

Flink version

1.14.6

Flink CDC version

3.0.0

Database and its version

starrocks 2.5.2

Minimal reproduce step

按照以下教程操作的: https://ververica.github.io/flink-cdc-connectors/master/content/%E5%BF%AB%E9%80%9F%E4%B8%8A%E6%89%8B/mysql-starrocks-pipeline-tutorial-zh.html

What did you expect to see?

成功读取mysql,落库starrocks

What did you see instead?

image

读取mysql成功,创建StarRocksDataSink失败

Anything else?

image

官网宣称flinkcdc 3.0支持1.14.*

Are you willing to submit a PR?

  • [ ] I'm willing to submit a PR!

cleverUtd avatar Feb 05 '24 09:02 cleverUtd

org/apache/flink/api/connector/sink2/Sink.java is be added to flink project in flink1.15 version. i think 3.0.* don't support flink1.14 version. i think docs is not correct.

dufeng1010 avatar Feb 23 '24 14:02 dufeng1010

Considering collaboration with developers around the world, please re-create your issue in English on Apache Jira under project Flink with component tag Flink CDC. Thank you!

PatrickRen avatar Mar 20 '24 06:03 PatrickRen