240 发简信
IP属地:上海
  • Kafka broker 存储不均衡问题排查记录

    背景 Kafka原本集群磁盘扩容后,新建topic的业务量较大,存在数据积压。一段时间后收到集群节点报警,部分磁盘使用率到达90%警戒值。经过检查发现问题节点各磁盘使用率不均...

  • Flink SQL 实战之 MAP 类型在 UNION ALL 中的妙用

    前言 工作当中我们往往会遇到这样的需求场景:某张表中不同的统计指标,需要从多个不同的 kafka 数据源当中统计。这种做法,我们很容易想到把多个 kafka source 统...

  • 120
    Flink CEP的基石:NFA-b自动机原理简介

    前言 Flink的复杂事件处理(complex event processing, CEP)库能够在无界数据流中通过匹配定义好的事件模式来发现一系列事件之间的关联规律,从而有...

  • 求更新

    Flink Sql教程(3)

    维表Join尝鲜 什么是维表 维表,维度表的简称,来源于数据仓库,一般用来给事实数据补充信息。假设现在有一张销售记录表。销售记录表里面的一条销售记录就是一条事实数据,而这条销...