最近遇到一个很奇怪的问题，Flink任务正常启动正常运行一段时间后就会报错，,错误详情如下 初步判断应该是触发了akka的超时机制，那就先调整集群的akka超时间配置，在conf/flink-conf.yaml最后增加下面参数 观察Job Manager ...

分类 properties josn yaml hocon 轻松支持比较复杂的配置 除了properties 和 json 在复杂的配置文件下，可选择YAML或HOCON YAML ...

akka actor, akka cluster akka是一系列框架，包括akka-actor, akka-remote, akka-cluster, akka-stream等，分别具有高并发处理模型——actor模型，远程通信，集群管理，流处理等功能。 akka支持scala和java ...

利用多线程可以通过并行执行任务来提升效率，但是很多场景下，不是所有的任务都是可以一起执行的，现实情况是有的任务必须要等到之前那些可并行的任务都执行后才可以继续执行的。考虑如下任务场景： 任 ...

  akka集群是高容错、去中心化、不存在单点故障以及不存在单点瓶颈的集群。它使用gossip协议通信以及具备故障自动检测功能。 Gossip收敛   集群中每一个节点被其他节点监督(默认的最大数量为5)。集群中的节点互相监督着，某节点所监督的状态也正在被其他监督着。通过gossip协议 ...

akka系列文章目录 akka学习教程(十四) akka分布式实战 akka学习教程(十三) akka分布式 akka学习教程(十二) Spring与Akka的集成 akka学习教程(十一) akka持久化 akka学习教程(十) agent akka学习教程 ...

的结果。因此Actor在空间（分布式）和时间（异步驱动）上解耦的。而Akka是Lightbend（前身是Ty ...

AKKA简介 什么是AKKA Akka是一个由Scala编写的,能兼容Sacala和JAVA的,用于编写高可用和高伸缩性的Actor模型框架.它基于了事件驱动的并发处理模式,性能非常的高,并且有很高的可用性.大大的简化了我们在应用系统中开发并发处理的过程.它在各个领域都有很好的表现. 使用 ...

AKKA HTTP 简单示例 依赖包： 代码示例： 启动后访问地址 http://127.0.0.1:8888/hello 返回Say hello to akka-http ...

Actor 类定义 Actor 类需要继承AbstractActor类 实现createReceive方法,绑定各类actor收到不同类型消息对应处理不同业务逻辑 默认提供了ReceiveBu ...