В кеш памяти для Flink (Scala)?Невозможно загрузить гуаву - PullRequest
Новая
       42

В кеш памяти для Flink (Scala)?Невозможно загрузить гуаву

0 голосов
/ 19 марта 2019

Я хочу использовать кэш в памяти в моем задании Flink (Scala), чтобы я мог установить TTL (время жизни) для ключей. Я искал решение и нашел гуаву. Однако я не уверен, работает ли он с Flink (v 1.6.3 - Scala), поскольку я не могу загрузить любую версию Guava в оболочку Flink. 

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.

Есть ли альтернативы? Любая помощь в устранении этой ошибки?

1 Ответ

0 голосов
/ 20 марта 2019

Может быть, вы можете попробовать Flink State Keyed State с TTL в FLink 1.6. Смотрите здесь Флинк официальный документ. .

...