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

支持 Flink 1.15.x 下作为Lookup Table #30

Closed
MingYu-Deng opened this issue Feb 23, 2023 · 2 comments
Closed

支持 Flink 1.15.x 下作为Lookup Table #30

MingYu-Deng opened this issue Feb 23, 2023 · 2 comments

Comments

@MingYu-Deng
Copy link

现有程序跑在Flink 1.14.x下完全正常。但当跑在Flink 1.15.x下,会因为RedisDynamicTableFactory所依赖的Cache类是 com.google.common.cache.Cache 是旧版本Flink 1.14.x的包,新版本包路径已经改为:org.apache.flink.shaded.guava30.com.google.common.cache.Cache(依赖包是flink-shaded-guava),所以 flink-connector-redis 1.2.3 跑在 1.15.x 下时,如果只是作为sink是不会出错的,但当作为lookup table就会出错。

希望可以更新依赖包。

@jeff-zou
Copy link
Owner

jeff-zou commented Feb 28, 2023 via email

@jeff-zou
Copy link
Owner

已更新,请使用:

<dependency>
			<groupId>io.github.jeff-zou</groupId>
			<artifactId>flink-connector-redis</artifactId>
			<version>1.2.7</version>
			<scope>provided</scope>
		</dependency>

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

2 participants