七、OperatorState 样例 1：使用 BroadcastState 实现双流连接 1，需求说明 （1）针对 BroadcastState 的使用，一个典型的应用案例就是两个流连接的场景。 假设其中一个数据流是“事件数据流”，它属于普通的数据流，里面是一些用户行为数据。 另外一个数据流是“配置数据流”，它不是普通的数据流......
六、OperatorState 样例 1：ListState 实现有状态的批量输出功能 1，需求说明 我们想要实现一个批量输出的功能，此时可以考虑在 Sink 组件内部定义一个缓存，但是还要保证数据一定会输出到外部系统。 2，实现逻辑 这个时候就需要借助于状态实现了，通过 CheckpointedFunction 接口......
四、KeyedState 样例 4：使用带有状态的算子 1，使用 Keyed State 的 3 种形式 （1）通过重写 RichXXXFunction，在里面创建和操作状态。 例如针对 map 算子可以使用 RichMapFunction，针对 flatmap 算子可以使用 RichFlatMapFunction 等。 在这里使用对应的 RichFunction 主要是因为它里面提供了......
四月头条：昔日20强语言Kotlin、Ruby与Swift处境艰难 在 TIOBE 编程语言排行榜中，Kotlin、Ruby 和 Swift 一直稳居前二十名，直到最近才开始动摇。如今，它们似乎失去了吸引力，有可能逐渐被淘汰。Kotlin 与 Swift 的衰落原因如出一辙：二者分别专用于移动平台 Android 和 iOS......
三、KeyedState 样例 3：使用 ListState 实现订单数据补全（双流 Join） 1，需求说明 大致需求是这样的，某外卖平台需要开发一个实时订单消息推送功能，当用户下单，并且成功支付后向商家推送一条消息。 2，实现逻辑 （1）由于下单数据是一个数据流，支付数据是另外一个数据流。 订单数据流......
、KeyedState 样例 1：MapState 实现直播间数据统计 1，需求说明 大致需求是这样的，需要统计平台中每个主播在直播间内收到的礼物信息、点赞、关注等指标，以直播间为单位进行统计。 2，实现逻辑 （1）由于用户每次开播都会生成一个新的直播间 vid.......
一、KeyedState 样例 1：使用 ValueState 实现温度告警 1，需求说明 大致需求是这样的，某机房内的多个设备会实时上报温度信息，在 Flink 任务内部需要对设备最近两次的温度进行对比，如果温差超过了 20 度，则需要发送告警信息，说明设备出问题了......
一、基本介绍 1，什么是 State？ （1）在流式计算中，State（状态）用于保存任务的中间数据或上下文信息。状态可以帮助任务跟踪事件间的依赖关系，从而实现复杂的业务逻辑，例如聚合、窗口计算或故障恢复。 （2）下图里面显示了 Flink 在对金融数据实现实时累加求和时的业务场景......
我在之前的文章中讲到在某些特殊情况下会导致任务无法从 Savepoint 中恢复。下面来针对两个比较常见的故障场景进行分析： 故障情况1：未手工设置 uid，重启时任务中增加了新的算子 故障情况2：未手工设置 uid，重启时算子并行度发生了变化......
一、手工触发 Savepoint 1，准备任务 jar 包 （1）首先我们准备一个有状态的单词计数案例 （2）然后将其打包，并将生成的 jar 包上传到集群服务器中。 2，运行测试 （1）我们首先通过在终端运行如下命令来启动一个监听本地 9999 端口的 TCP socket......