Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[Bug] cdc 3.0.1和flink 1.16.2 集成存在依赖冲入问题 #3071

Closed
1 of 2 tasks
WuChongYong opened this issue Feb 21, 2024 · 5 comments
Closed
1 of 2 tasks

[Bug] cdc 3.0.1和flink 1.16.2 集成存在依赖冲入问题 #3071

WuChongYong opened this issue Feb 21, 2024 · 5 comments
Labels
bug Something isn't working

Comments

@WuChongYong
Copy link

Search before asking

  • I searched in the issues and found nothing similar.

Flink version

1.16.2

Flink CDC version

3.0.1

Database and its version

mysql 5.7.26

Minimal reproduce step

guava 依赖冲突,cdc的guava依赖是

org.apache.flink
flink-shaded-guava
30.1.1-jre-16.2

flink 1.16.2的guava依赖是

org.apache.flink
flink-shaded-guava
31.1-jre-17.0

运行官网样例的api会报类找不到:
Caused by: java.lang.NoClassDefFoundError: org/apache/flink/shaded/guava31/com/google/common/util/concurrent/ThreadFactoryBuilder

如果剔除cdc的guava包,引入31的guava包,也会出现其他类的找不到
Exception in thread "main" java.lang.NoClassDefFoundError: org/apache/flink/shaded/guava30/com/google/common/collect/Lists

What did you expect to see?

希望3.0.1之后cdc版本能准确和flink 1.14以上的版本互相兼容

What did you see instead?

但目前3.0.1之后cdc版本能准确和flink 1.16.2 的版本不兼容

Anything else?

No response

Are you willing to submit a PR?

  • I'm willing to submit a PR!
@WuChongYong WuChongYong added the bug Something isn't working label Feb 21, 2024
@loserwang1024
Copy link
Contributor

loserwang1024 commented Feb 21, 2024

@WuChongYong
Unlike flink-table-commonflink-connector-base flink-core whose maven scope is provided , flink-shaded-guava and flink-shaded-force-shading will be included in the final jar package, causing dependency conflict.

Now we can see why dependency conflict occurs:

  • Since Flink 1.18, version of guava is upgrade from 30 to 31.
image
  • Since CDC 3.0, version of guava is also upgrade from 30 to 31

  • So CDC 3.0 is compatible with Flink 1.18, CDC 2.x is is compatible with Flink 1.13-1.17. CDC 2.x and Flink 1.18 dependency conflict, CDC 3.0 and Flink 1.17 dependency conflict.

Thus, both dependencies should be shaded relocations in pom.xml.
By the way, please use English so that foreign developers can also refer to this issue.

@leonardBang , @ruanhang1993 , @PatrickRen CC, WDYT?

@YyItRoad
Copy link

和我的一样我用的是flink 1.17.2 和 flink-connector-mongodb-cdc 3.0.1也出现这个问题, 然后我将flink-connector-mongodb-cdc降到2.4.2才正常

@loserwang1024
Copy link
Contributor

@WuChongYong , @YyItRoad , hi, Please give me your code so that I can reproduce it.

@WuChongYong
Copy link
Author

WuChongYong commented Mar 6, 2024 via email

@PatrickRen
Copy link
Contributor

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!

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
bug Something isn't working
Projects
None yet
Development

No branches or pull requests

4 participants