硅基社区
标签频道

流计算

该标签下的文章、提问与讨论帖。

文 Flink checkpoint 对齐把反压放大 3 倍:一次 checkpoint 耗时从 800ms 飙到 22s 的根因、unaligned 开关与它的 3 个隐性坑
Flink checkpoint 对齐把反压放大 3 倍:一次 checkpoint 耗时从 800ms 飙到 22s 的根因、unaligned 开关与它的 3 个隐性坑 一、现象与背景 先给数字。我们一条实时风控特征管道:Flink 1
帖 数据倾斜治理:「均匀化打散」和「热 key 隔离」到底谁先谁后?聊聊你的直觉与底线
背景 做数据工程 5 年,我几乎每个月都要和"倾斜"打交道:Flink 的 keyBy 热 key 让某个 subtask 的 RocksDB 写入 QPS 飙到均值的 30 倍、Kafka 消费组里某个分区被一条大商家消息拖到 5 分钟才