flink-cdc
flink-cdc copied to clipboard
[Bug] 3.0 StarRocksDataSink不支持 flink1.14 【java.lang.NoClassDefFoundError: org/apache/flink/api/connector/sink2/Sink】
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?
读取mysql成功,创建StarRocksDataSink失败
Anything else?
官网宣称flinkcdc 3.0支持1.14.*
Are you willing to submit a PR?
- [ ] I'm willing to submit a PR!
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.
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!