在Kubernetes上使用Akka进行调度时，可以使用以下代码示例来处理宕机或不可达的节点：

import akka.actor.{Actor, ActorSystem, Props}
import akka.cluster.Cluster
import akka.cluster.ClusterEvent._

class MyActor extends Actor {
  val cluster = Cluster(context.system)

  override def preStart(): Unit = {
    cluster.subscribe(self, classOf[MemberEvent], classOf[UnreachableMember])
  }

  override def postStop(): Unit = {
    cluster.unsubscribe(self)
  }

  def receive: Receive = {
    case MemberUp(member) =>
      // 处理新加入的节点
      println(s"${member.address} is up")
    case UnreachableMember(member) =>
      // 处理不可达的节点
      println(s"${member.address} is unreachable")
    case MemberRemoved(member, previousStatus) =>
      // 处理被移除的节点
      println(s"${member.address} is removed")
    case _: MemberEvent =>
    // 忽略其他MemberEvent
  }
}

object MyApp extends App {
  val system = ActorSystem("MyApp")
  val myActor = system.actorOf(Props[MyActor], "myActor")
}

在上述代码中，我们定义了一个MyActor类，它订阅了MemberEvent和UnreachableMember事件。MemberUp事件用于处理新加入的节点，UnreachableMember事件用于处理不可达的节点，MemberRemoved事件用于处理被移除的节点。

在MyApp对象中，我们创建了一个名为"MyApp"的ActorSystem，并使用Props[MyActor]创建了一个MyActor实例。这样，当MyActor被创建时，它会自动订阅集群事件，并在接收到事件时执行相应的处理逻辑。

这样，当有节点宕机或不可达时，Akka集群会发送相应的事件给MyActor，并执行相应的处理逻辑。你可以根据自己的需求，修改代码中的处理逻辑来适应具体的场景。