在Flink (Scala)的内存缓存中？无法加载Guava

Question

我想在我的Flink作业(Scala)中使用内存中的缓存，这样我就能够为键设置TTL (生存时间)。我一直在寻找解决方案，找到了芭乐。但是，我不确定它是否适用于Flink (v1.6.3- Scala)，因为我无法在Flink shell中加载任何版本的Guava。

scala> :require flink-shaded-guava-18.0-6.0.jar
The path 'flink-shaded-guava-18.0-6.0.jar' cannot be loaded, because existing classpath entries conflict.

scala> :require flink-shaded-guava-18.0-5.0.jar
The path 'flink-shaded-guava-18.0-5.0.jar' cannot be loaded, because existing classpath entries conflict.

scala> :require flink-shaded-guava-18.0-4.0.jar
The path 'flink-shaded-guava-18.0-4.0.jar' cannot be loaded, because existing classpath entries conflict.

scala> :require flink-shaded-guava-18.0-3.0.jar
The path 'flink-shaded-guava-18.0-3.0.jar' cannot be loaded, because existing classpath entries conflict.

scala> :require flink-shaded-guava-18.0-2.0.jar
The path 'flink-shaded-guava-18.0-2.0.jar' cannot be loaded, because existing classpath entries conflict.

scala> :require flink-shaded-guava-18.0-1.0.jar
The path 'flink-shaded-guava-18.0-1.0.jar' cannot be loaded, because existing classpath entries conflict.

还有别的选择吗？对解决这个错误有什么帮助吗？

Answer 1

也许你可以尝试在Flink 1.6中使用TTL原生键控状态。看这里，Flink official doc.。