Akka Cluster Scheduler -节点宕机时会发生什么情况
Akka Cluster Scheduler是Akka框架中的一个模块，用于在Akka集群中调度任务。当节点宕机时，Akka Cluster Scheduler会根据配置的策略来处理宕机节点的情况。
具体情况取决于所配置的策略，以下是一些可能的情况：
- 任务迁移：如果配置了任务迁移策略，当节点宕机时，Akka Cluster Scheduler会将该节点上的任务迁移到其他健康的节点上继续执行。这可以确保任务的连续性和高可用性。
- 任务重试：如果配置了任务重试策略，当节点宕机时，Akka Cluster Scheduler会将任务重新分配给其他可用节点执行。这可以确保任务不会因为节点宕机而丢失，并且可以在其他节点上继续执行。
- 任务暂停：如果配置了任务暂停策略，当节点宕机时，Akka Cluster Scheduler会暂停该节点上的任务，直到节点恢复正常。这可以避免任务在宕机节点上执行失败，并等待节点恢复后再继续执行。
- 任务取消：如果配置了任务取消策略，当节点宕机时，Akka Cluster Scheduler会取消该节点上的任务，并将其标记为失败。这可以避免任务在宕机节点上继续执行，并且可以通知相关的系统或用户任务已经失败。
需要注意的是，Akka Cluster Scheduler的具体行为取决于所配置的策略和集群的状态。在设计和配置时，需要考虑到任务的重要性、执行时间、数据一致性等因素，以确保系统的可靠性和性能。
腾讯云提供了一系列与Akka Cluster Scheduler相关的产品和服务，例如云服务器、容器服务、负载均衡等，可以根据具体需求选择适合的产品。更多关于腾讯云产品的信息，请参考腾讯云官方网站：https://cloud.tencent.com/
相关·内容
因此，如果在一个节点上调度某项任务，如果它停机，则所有计划的任务都将被丢弃。 如果我创建一个负责调度的集群Singleton，那么在其他节点上重新创建后，已经创建的调度还能继续存在吗？
浏览 39提问于2021-02-01得票数 0
回答已采纳
1回答
假设集群中有2个节点，并且有一个负载均衡器，当一个处理少量HTTP请求的节点宕机时会发生什么情况，这些请求会发生什么情况？它们是否会丢失，或者因为集群，挂起的请求将被移动到集群中的另一个节点。
浏览 3提问于2016-08-30得票数 0
1回答
我们可以通过启动种子节点，然后启动其他节点，让我们的集群按照设计的方式工作，但如果任何一个节点宕机，似乎唯一能让它们重新说话的方法就是以同样的方式重新启动整个集群。当我关闭非种子节点时，种子节点将其标记为不可达，并开始定期记录以下内容：
Association with remote system [akka.tcp://application@xxx.xx.x.xxx但是，当我重新启动节点时，新启动的节点开始重复
浏览 8提问于2018-01-31得票数 1
回答已采纳
主节点和种子节点是相同的。来自不同的项目，我正在尝试添加到集群中，并希望发送消息。我可以加入集群，但不能发送消息。我的主节点和种子节点： import akka.actor._ |akka.cluster.roles = ["$role"]
|akk
浏览 0提问于2017-08-06得票数 0
1回答
Akka-Cluster模块用于应用程序内的集群。如果我们有一个设置，在节点上运行的实体参与者(我们可能有数百个参与者分布在节点上)被调度为每1分钟接收一次消息(使用计时器/调度器)，那么当托管该参与者的节点优雅地和不优雅地关闭时会发生什么
我们如何确保实体参与者在另一个节点上自动创建另外，参与者的调度器发生了什么情况。迁移到其他节点后，是否可以在执行元上自动运行调度程序。注意:到目前为止
浏览 3提问于2021-04-15得票数 0
我在DataStax Enterprise4.7 (DSE)上使用Spark1.2.1作为三个节点(AWS服务器)的独立集群。当从主节点启动应用程序时，它通过第一阶段，但在第二阶段得到一个“远程Akka客户端断开关联”错误。此外，我还被要求删除不存在的执行器0“错误。
没有纱线。错误2015-07-09 12:59:24 org.apache.spark.scheduler.cluster.SparkDeploySchedulerBackend:要求删除不存在的执行程序1错误2015-07-09 12
浏览 3提问于2015-07-09得票数 4
回答已采纳
(0 + 2) / 2]16/01/20 10:10:24 ERROR org.apache.spark.scheduler.cluster.YarnScheduler16/01/20 10:10:24 WARN akka.remote.ReliableDeliverySupervisor: Association with remote system [akka.tcp下面是另一个示例：
20 10:51:43 ERROR org.apache.spark.<e
浏览 0提问于2016-01-20得票数 1
1回答
我使用Akka.NET的集群(1.0.5)功能来实现一个服务，该服务由一个主节点组成，该节点通过HTTP接收请求，并将工作分配给已加入集群的工作节点。第一点如您所期望的那样工作:一个新实例(Azure角色)被拆分，并加入主节点--也是种子节点。不幸的是，这似乎并没
浏览 1提问于2015-12-07得票数 2
回答已采纳
1回答
我创建了一个具有3个节点(标准DS3 v2 (4vcpu，14 GB内存))的azure AKS。我在摆弄集群，创建了一个1000 replicas.After的部署这个完整的集群宕机了。10251: getsockopt: connection refused 从调试情况看，Scheduler和Controller-manager似乎都宕机了。创建包含1000个副本的部
浏览 5提问于2018-02-05得票数 0
回答已采纳
1回答
我正在尝试创建一个Akka切分集群。我希望在其中一个节点上使用代理模式，只将消息路由到碎片区域。= ["akka.cluster.metrics.ClusterMetricsExtension", "akka.cluster.ddata.DistributedData"]
messgaeProducer { actor {
provider = "akka
浏览 3提问于2019-02-11得票数 3
1回答
我有一个具有2个节点的Akka集群，并使用滚动更新策略进行部署。 Actor A向Actor B发送一条消息，并成为一种等待回复的行为。matchAny(msg -> sender.tell("COMPLETE", getSelf())) }
} 部署是同时进行的，因此包含Actor A的节点会收到根据我对Akka文档的理解，正常关闭包括向节点上的所有参与者发送PoisonPill。 那么Actor A会发生</
浏览 6提问于2019-05-18得票数 0
3回答
client.AppClient$ClientActor: Connecting to master spark://172.17.0.3:7077...我检
浏览 1提问于2014-05-28得票数 8
回答已采纳
我使用Akka.net集群特性实现了这个应用程序。写代码的人已经离开了公司。我正在努力理解代码，我们正在计划部署。
集群有2种节点类型。这种情况已经发生了5天左右，而且节点也从未消亡过。它的CPU和内存使用率很高。此外，当过滤搜索日志时，它没有任何队列处理器参与者运行。垃圾收集需要很长的时间。我在这个节点的日志中看到了以下内容。原因:akka.tcp://myapp@灯塔导致关联失败-1:7892由：[System.AggregateException:一个或多个错误
浏览 1提问于2021-09-08得票数 0
回答已采纳
我正在尝试Akka.Net集群工具，以便使用单例行为，而且它似乎工作得很好，但就在当前的单例节点“主机”以优雅的方式离开集群时。如果突然关闭主机节点，则不会发生切换。背景 suppress-json-serializer-warning = on
provider = "Akk
浏览 4提问于2016-08-08得票数 2
回答已采纳
我有一个需求，我需要连接几个hive表，并从该查询中获取最终数据，然后将该数据写入文件。有人能帮我这个忙吗。在这里，我附上了此作业执行的完整日志。
浏览 0提问于2015-12-04得票数 1
我有一个Akka集群，需要3个节点： seed-nodes = [ router = round-robin-pool clusterrouter.tell(message,
浏览 3提问于2018-06-30得票数 0
2回答
Akka单点故障
、、
)).props(Props[TestActor]),} implicit val ExecutionContext = context.dispatcheractor {
provider = "akka.cl
浏览 1提问于2017-01-21得票数 5
1回答
我正在用Akka.Cluster创建一个有三个节点A、B和C的示例，其中A是灯塔。到目前为止，从日志中看，当没有参与者或参与者是本地的(用spawn和spawnOpt创建)时，集群可以正常工作。类型的未处理异常发生在Akka.dll中
附加信息：Configuration problem while creating [akka://calculatorSystem/user/r-actor]let text = Console.ReadLine(
浏览 0提问于2016-08-31得票数 2
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
