Kubernetes 安装 入门 介绍 准备 Kubernetes 上的 Flink session 集群 部署模式 Application 集群模式 Per-Job 集群模式 Session 集群模式 Kubernetes 上运行 Standalone 集群指南 Configuration 在 Kubernets 上访问 Flink 调...

术语，概念 并发 vs. 并行 异步 vs. 同步 非阻塞 vs. 阻塞 死锁 vs. 饥饿 vs. 活锁 竞态条件 非阻塞担保（进展条件） 无等待（Wait-freedom） 无锁（Lock-freedom） 无阻碍（Obstruction-freedom） 推荐文献 术语，概念 这一章我们将尝试建立通用的术语，对Akka面向的...

Kubernetes 安装 入门 介绍 准备 Kubernetes 上的 Flink session 集群 部署模式 Application 集群模式 Per-Job 集群模式 Session 集群模式 Kubernetes 上运行 Standalone 集群指南 Configuration 在 Kubernets 上访问 Flink 调...

概述 概述 术语，概念 并发 vs. 并行 异步 vs. 同步 非阻塞 vs. 阻塞 死锁 vs. 饥饿 vs. 活锁 竞态条件 非阻塞担保（进展条件） 推荐文献 Actor系统 树形结构 配置容器 Actor最佳实践 阻塞需要仔细的管理 你不应该担心的事 什么是Actor? Actor引用 状态 行为 邮箱 子Actor 监管策略 ...

Actor 模型如何满足现代分布式系统的需求？ 消息传递的使用避免了锁和阻塞 Actor 能够优雅地处理错误情况 Actor 模型如何满足现代分布式系统的需求？ 如前一主题「为什么现代系统需要新的编程模型 」所述，常见的编程实践不能合适地满足现代系统的需求。幸运的是，我们不需要放弃我们所知道的一切。相反，Actor 模型以一种原则性的方式解决了这...

DataStream Connectors 预定义的 Source 和 Sink 附带的连接器Flink Project Connectors Apache Bahir 中的连接器 连接Flink的其他方法 异步 I/O DataStream Connectors 预定义的 Source 和 Sink 一些比较基本的 Source 和 Si...

使用TCP 连接 接受连接 关闭连接 写入一个连接 读写限流" level="3"> 读写限流 基于ACK的高压写 带有挂起的基于NACK高压写 带有拉取模式高压写 入站连接的拉取读模式 使用TCP 注：本节未经校验，如有问题欢迎提issue 贯穿本节的代码片段假定以下imports： import akka . act...

其他示例程序 非阻塞的作弊码 其他示例程序 快速入门 一个展示了Rector 基本组件数种使用方法的应用。 示例代码 一个通过 JUnit 测试演示 Reactor 功能的简单示例应用。 非阻塞的作弊码 如果你深入到这一步的话，这里有一个非阻塞数据流的示例，让你识别 websocket 中的作弊码。告诉我它的奖励… 不要忘记在 react...

Actor系统 树形结构 配置容器 Actor最佳实践 阻塞需要仔细的管理 你不应该担心的事 Actor系统 Actor是封装状态和行为的对象，他们唯一的通讯方式是交换消息——把消息存放在接收方的邮箱里。从某种意义上来说，actor是面向对象最严格的形式，不过最好把它们比作人：在使用actor来对解决方案建模时，把actor想象成一群人，把...

配置 常见选项 完整参考 HDFS 核心 JobManager TaskManager 分布式协调（通过Akka） REST Blob服务器 心跳管理器 SSL设置 网络通讯（通过Netty） Web前端 文件系统 编译/优化 运行时算法 Resource Manager YARN Mesos Mesos TaskManag...