Wait the light to fall

状态和容错性

焉知非鱼

State & Fault Tolerance

在本节中,您将了解 Flink 为编写有状态程序提供的 API。请看一下 Stateful Stream Processing,了解有状态流处理背后的概念。

下一步怎么走? #

  • 使用状态。展示如何在 Flink 应用中使用状态,并解释不同类型的状态。
  • 广播状态模式。解释如何连接一个广播流和一个非广播流,并使用状态在它们之间交换信息。
  • 检查点。描述了如何启用和配置检查点以实现容错。
  • 可查询状态。说明如何在运行时从 Flink 外部访问状态。
  • 状态模式演化:介绍如何在运行时从外部访问状态。展示了状态类型的模式如何演化。
  • 管理状态的自定义序列化。讨论如何实现自定义序列化,特别是针对模式演化。