我想在我的flink作业（scala）中使用内存缓存，以便我能够为钥匙设置一个TTL（live）。我一直在寻找解决方案并找到了番石榴。但是，我不确定它是否适用于Flink（V 1.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.
有其他选择吗？有助于解决此错误？
也许您可以在Flink 1.6中尝试使用TTL的Flink Native键入状态。请参阅Flink官方文档..