switch to pekko

Update AmberKryoInitializer.scala

scala-kryo-serialization

Update build.sbt

Update cluster.conf

Update cluster.conf

Update build.sbt

kryo5

Update AmberKryoInitializer.scala

Update AmberKryoInitializer.scala

Update cluster.conf

Update cluster.conf

Author: pjfanning

amber/build.sbt

@@ -49,23 +49,23 @@ Compile / unmanagedSourceDirectories += baseDirectory.value / "src" / "main" / "
 PB.generate / excludeFilter := "scalapb.proto"
 
 /////////////////////////////////////////////////////////////////////////////
-// Akka related
-val akkaVersion = "2.6.21"
-val akkaDependencies = Seq(
-  "com.typesafe.akka" %% "akka-actor" % akkaVersion,
-  "com.typesafe.akka" %% "akka-remote" % akkaVersion,
-  "com.typesafe.akka" %% "akka-cluster" % akkaVersion,
-  "com.typesafe.akka" %% "akka-cluster-metrics" % akkaVersion,
-  "com.typesafe.akka" %% "akka-cluster-tools" % akkaVersion,
-  "com.typesafe.akka" %% "akka-multi-node-testkit" % akkaVersion % Test,
-  "com.typesafe.akka" %% "akka-testkit" % akkaVersion % Test,
-  "com.typesafe.akka" %% "akka-persistence" % akkaVersion,
+// Pekko related
+val pekkoVersion = "1.2.1"
+val pekkoDependencies = Seq(
+  "org.apache.pekko" %% "pekko-actor" % pekkoVersion,
+  "org.apache.pekko" %% "pekko-remote" % pekkoVersion,
+  "org.apache.pekko" %% "pekko-cluster" % pekkoVersion,
+  "org.apache.pekko" %% "pekko-cluster-metrics" % pekkoVersion,
+  "org.apache.pekko" %% "pekko-cluster-tools" % pekkoVersion,
+  "org.apache.pekko" %% "pekko-multi-node-testkit" % pekkoVersion % Test,
+  "org.apache.pekko" %% "pekko-testkit" % pekkoVersion % Test,
+  "org.apache.pekko" %% "pekko-persistence" % pekkoVersion,
   "io.kamon" % "sigar-loader" % "1.6.6-rev002",
-  "com.softwaremill.macwire" %% "macros" % "2.5.8" % Provided,
-  "com.softwaremill.macwire" %% "macrosakka" % "2.5.8" % Provided,
-  "com.softwaremill.macwire" %% "util" % "2.5.8",
-  "com.softwaremill.macwire" %% "proxy" % "2.5.8",
-  "com.typesafe.akka" %% "akka-slf4j" % akkaVersion,
+  "com.softwaremill.macwire" %% "macros" % "2.6.7" % Provided,
+  "com.softwaremill.macwire" %% "macrospekko" % "2.6.7" % Provided,
+  "com.softwaremill.macwire" %% "util" % "2.6.7",
+  "com.softwaremill.macwire" %% "proxy" % "2.6.7",
+  "org.apache.pekko" %% "pekko-slf4j" % pekkoVersion,
   "ch.qos.logback" % "logback-classic" % "1.2.13" % Test
 )
 
@@ -137,7 +137,7 @@ val googleServiceDependencies = Seq(
   "com.sun.mail" % "javax.mail" % "1.6.2"
 )
 
-libraryDependencies ++= akkaDependencies
+libraryDependencies ++= pekkoDependencies
 libraryDependencies ++= luceneDependencies
 libraryDependencies ++= dropwizardDependencies
 libraryDependencies ++= mbknorJacksonJsonSchemaDependencies
@@ -222,8 +222,15 @@ libraryDependencies += "org.jooq" % "jooq" % "3.14.16"
 // https://mvnrepository.com/artifact/org.jgrapht/jgrapht-core
 libraryDependencies += "org.jgrapht" % "jgrapht-core" % "1.4.0"
 
-// https://mvnrepository.com/artifact/io.altoo/akka-kryo-serialization
-libraryDependencies += "io.altoo" %% "akka-kryo-serialization" % "2.5.2"
+// https://mvnrepository.com/artifact/com.esotericsoftware/kryo
+libraryDependencies += "com.esotericsoftware" % "kryo" % "5.6.2"
+libraryDependencies += "com.esotericsoftware" % "kryo5" % "5.6.0"
+
+// https://mvnrepository.com/artifact/io.altoo/pekko-kryo-serialization
+libraryDependencies += "io.altoo" %% "pekko-kryo-serialization" % "1.3.0"
+
+// https://mvnrepository.com/artifact/io.altoo/scala-kryo-serialization
+libraryDependencies += "io.altoo" %% "scala-kryo-serialization" % "1.3.0"
 
 // https://mvnrepository.com/artifact/com.twitter/util-core
 libraryDependencies += "com.twitter" %% "util-core" % "22.12.0"

amber/src/main/scala/org/apache/amber/clustering/ClusterListener.scala

@@ -19,9 +19,9 @@
 
 package org.apache.amber.clustering
 
-import akka.actor.{Actor, Address}
-import akka.cluster.Cluster
-import akka.cluster.ClusterEvent._
+import org.apache.pekko.actor.{Actor, Address}
+import org.apache.pekko.cluster.Cluster
+import org.apache.pekko.cluster.ClusterEvent._
 import com.google.protobuf.timestamp.Timestamp
 import com.twitter.util.{Await, Future}
 import org.apache.amber.clustering.ClusterListener.numWorkerNodesInCluster

amber/src/main/scala/org/apache/amber/clustering/SingleNodeListener.scala

@@ -19,7 +19,7 @@
 
 package org.apache.amber.clustering
 
-import akka.actor.{Actor, ActorLogging}
+import org.apache.pekko.actor.{Actor, ActorLogging}
 import org.apache.amber.clustering.ClusterListener.GetAvailableNodeAddresses
 
 class SingleNodeListener extends Actor with ActorLogging {

amber/src/main/scala/org/apache/amber/engine/architecture/common/AkkaActorRefMappingService.scala

@@ -19,7 +19,7 @@
 
 package org.apache.amber.engine.architecture.common
 
-import akka.actor.ActorRef
+import org.apache.pekko.actor.ActorRef
 import org.apache.amber.core.virtualidentity.{ActorVirtualIdentity, ChannelIdentity}
 import org.apache.amber.engine.architecture.common.WorkflowActor.{
   CreditRequest,

amber/src/main/scala/org/apache/amber/engine/architecture/common/AkkaActorService.scala

@@ -19,8 +19,9 @@
 
 package org.apache.amber.engine.architecture.common
 
-import akka.actor.{ActorContext, ActorRef, Address, Cancellable, Props}
-import akka.util.Timeout
+import org.apache.pekko
+import pekko.actor.{ActorContext, ActorRef, Address, Cancellable, Props}
+import pekko.util.Timeout
 import org.apache.amber.core.virtualidentity.ActorVirtualIdentity
 import org.apache.amber.engine.common.FutureBijection._
 
@@ -78,7 +79,7 @@ class AkkaActorService(val id: ActorVirtualIdentity, actorContext: ActorContext)
   }
 
   def ask(ref: ActorRef, message: Any): com.twitter.util.Future[Any] = {
-    akka.pattern.ask(ref, message).asTwitter()
+    pekko.pattern.ask(ref, message).asTwitter()
   }
 
 }

amber/src/main/scala/org/apache/amber/engine/architecture/common/AkkaMessageTransferService.scala

@@ -19,7 +19,7 @@
 
 package org.apache.amber.engine.architecture.common
 
-import akka.actor.Cancellable
+import org.apache.pekko.actor.Cancellable
 import org.apache.amber.config.ApplicationConfig
 import org.apache.amber.core.virtualidentity.{ActorVirtualIdentity, ChannelIdentity}
 import org.apache.amber.engine.architecture.common.WorkflowActor.NetworkMessage

amber/src/main/scala/org/apache/amber/engine/architecture/common/ExecutorDeployment.scala

@@ -19,8 +19,8 @@
 
 package org.apache.amber.engine.architecture.common
 
-import akka.actor.{Address, Deploy}
-import akka.remote.RemoteScope
+import org.apache.pekko.actor.{Address, Deploy}
+import org.apache.pekko.remote.RemoteScope
 import org.apache.amber.core.workflow.{PhysicalOp, PreferController, RoundRobinPreference}
 import org.apache.amber.engine.architecture.controller.execution.OperatorExecution
 import org.apache.amber.engine.architecture.deploysemantics.AddressInfo

amber/src/main/scala/org/apache/amber/engine/architecture/common/WorkflowActor.scala

@@ -19,9 +19,9 @@
 
 package org.apache.amber.engine.architecture.common
 
-import akka.actor.{Actor, ActorRef, Address, Stash}
-import akka.pattern.ask
-import akka.util.Timeout
+import org.apache.pekko.actor.{Actor, ActorRef, Address, Stash}
+import org.apache.pekko.pattern.ask
+import org.apache.pekko.util.Timeout
 import org.apache.amber.clustering.ClusterListener.GetAvailableNodeAddresses
 import org.apache.amber.core.virtualidentity.{ActorVirtualIdentity, ChannelIdentity}
 import org.apache.amber.engine.architecture.common.WorkflowActor._

amber/src/main/scala/org/apache/amber/engine/architecture/controller/Controller.scala

@@ -19,8 +19,8 @@
 
 package org.apache.amber.engine.architecture.controller
 
-import akka.actor.SupervisorStrategy.Stop
-import akka.actor.{AllForOneStrategy, Props, SupervisorStrategy}
+import org.apache.pekko.actor.SupervisorStrategy.Stop
+import org.apache.pekko.actor.{AllForOneStrategy, Props, SupervisorStrategy}
 import org.apache.texera.web.model.websocket.response.RegionUpdateEvent
 import org.apache.amber.config.ApplicationConfig
 import org.apache.amber.core.virtualidentity.ChannelIdentity

amber/src/main/scala/org/apache/amber/engine/architecture/controller/ControllerTimerService.scala

@@ -19,7 +19,7 @@
 
 package org.apache.amber.engine.architecture.controller
 
-import akka.actor.Cancellable
+import org.apache.pekko.actor.Cancellable
 import org.apache.amber.engine.architecture.common.AkkaActorService
 import org.apache.amber.engine.architecture.rpc.controlcommands.{
   AsyncRPCContext,