From a50b53ed6a58da189de4bbdca31ff25494c9b713 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Micha=C5=82=20Goworko?= Date: Fri, 13 Dec 2024 12:38:39 +0100 Subject: [PATCH] Scala 2.12 fix --- .../db/PeriodicProcessesRepositoryCachingDecorator.scala | 2 ++ 1 file changed, 2 insertions(+) diff --git a/engine/flink/management/periodic/src/main/scala/pl/touk/nussknacker/engine/management/periodic/db/PeriodicProcessesRepositoryCachingDecorator.scala b/engine/flink/management/periodic/src/main/scala/pl/touk/nussknacker/engine/management/periodic/db/PeriodicProcessesRepositoryCachingDecorator.scala index 643cb55d87f..cbf4f42ef5a 100644 --- a/engine/flink/management/periodic/src/main/scala/pl/touk/nussknacker/engine/management/periodic/db/PeriodicProcessesRepositoryCachingDecorator.scala +++ b/engine/flink/management/periodic/src/main/scala/pl/touk/nussknacker/engine/management/periodic/db/PeriodicProcessesRepositoryCachingDecorator.scala @@ -23,12 +23,14 @@ class PeriodicProcessesRepositoryCachingDecorator( private val activeSchedulesCache: AsyncCache[Int, Map[ProcessName, SchedulesState]] = Caffeine .newBuilder() + .asInstanceOf[Caffeine[Int, Map[ProcessName, SchedulesState]]] .expireAfterWrite(java.time.Duration.ofMillis(cacheTTL.toMillis)) .buildAsync[Int, Map[ProcessName, SchedulesState]] private val inactiveSchedulesCache: AsyncCache[(Int, Int), Map[ProcessName, SchedulesState]] = Caffeine .newBuilder() + .asInstanceOf[Caffeine[(Int, Int), Map[ProcessName, SchedulesState]]] .expireAfterWrite(java.time.Duration.ofMillis(cacheTTL.toMillis)) .buildAsync[(Int, Int), Map[ProcessName, SchedulesState]]