标签：#flink

基于Flink的网约车实时大数据监控系统：从0到1的全栈实战 文章目录基于Flink的网约车实时大数据监控系统：从0到1的全栈实战前...

admin2026-07-18服务器技术 阅读(46)评论(0)赞(0)

Flink Agents：外部副作用一致性 (ActionStateStore) 演进分析 本篇主要分析 Flink Agents 框架中为了解...

admin2026-07-16服务器技术 阅读(40)评论(0)赞(0)

一、前言 在上一篇文章中，我们深入学习了Flink的时间语义与水位线机制。本文将继续探索Flink流处理的高级特性——双流联结与处理函数。 双流联...

admin2026-07-09服务器技术 阅读(36)评论(0)赞(0)

一：水位线定义1：事件时间和窗口在窗口的处理过程中，我们可以基于数据的时间戳，自定义个“逻辑时钟”。这个...

admin2026-07-09服务器技术 阅读(23)评论(0)赞(0)

本项目版本：Flink 1.12（旧版 FlinkKafkaProducer EXACTLY_ONCE 语义） 场景&...

admin2026-07-09服务器技术 阅读(22)评论(0)赞(0)

一、什么是 ZooKeeper ZooKeeper 是 Apache 基金会开源的分布式协调服务，最初由 Yahoo! 开发，后来...

admin2026-07-09服务器技术 阅读(52)评论(0)赞(0)

Flink 的并行，不是多线程的混乱并发，而是多 Task 协同并行与单线程确定执行的完美结合； 它让每一条流水线有序...

admin2026-07-09服务器技术 阅读(28)评论(0)赞(0)

一、前言实时数据流中重复数据是十分常见的问题：上游 MQ 重试、网络抖动、业务重发都会产生重复消息，如果不做去重处理，...

admin2026-06-27服务器技术 阅读(38)评论(0)赞(0)

本文系统解析大数据开发中几个核心概念差异，涵盖Hive与Spark的关系、SparkSQL与HiveSQL的区别、PySpark与SparkSQL...

admin2026-06-26服务器技术 阅读(39)评论(0)赞(0)

一、引言Flink计算引擎已成为大数据实时计算领域的事实标准，然而还是有不少应用场景不适合使用Flink进行实时加工与关联计算，本文...

admin2026-06-26服务器技术 阅读(40)评论(0)赞(0)