akka-loader: freezes fix

Blackmorse · Jul 13, 2024 · 24ae75e · 24ae75e
1 parent 7411ef9
commit 24ae75e
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 1 deletion.
diff --git a/Dockerfile_akka_loader b/Dockerfile_akka_loader
@@ -6,4 +6,4 @@ RUN sbt akkaLoader/assembly
 FROM eclipse-temurin:11.0.21_9-jre-jammy
 WORKDIR /app/
 COPY --from=sources /app/akka-loader/target/scala-2.13/akka-loader-assembly-0.1.jar /app/
-ENTRYPOINT ["java", "-Xmx6096m", "-Xms256m", "-jar", "/app/akka-loader-assembly-0.1.jar"]
+ENTRYPOINT ["timeout", "4h", "java", "-Xmx6096m", "-Xms256m", "-jar", "/app/akka-loader-assembly-0.1.jar"]
diff --git a/akka-loader/src/main/scala/LoaderApp.scala b/akka-loader/src/main/scala/LoaderApp.scala
@@ -78,6 +78,10 @@ object LoaderApp extends App {
     case e: Throwable =>
       logger.error(e.getMessage, e)
       actorSystem.terminate()
+
+      // clickhouse-scheduled may not be terminated
+      Thread.sleep(10000)
+      System.exit(0)
   }
 
   private def executorAndScheduler(entity: String, lastMatchesWindow: Int, executorActorFactory: ExecutorActorFactory, worldDetails: WorldDetails): (ActorRef, AbstractScheduler) = {