在之前那篇讲解Flink Timer的文章里，我曾经用三言两语简单解释了Key Group和KeyGroupRange的概念。实际上，Key Group是Fli...
大数据领域SQL化的风潮方兴未艾（所谓"Everybody knows SQL"），Flink自然也不能“免俗”。Flink SQL是Flink系统内部最高级别...
虽然笔者之前写过基于Prometheus PushGateway搭建Flink监控的过程，但是在我们的生产环境中，使用的是InfluxDB。InfluxDB是一...
ack 数据源是否需要kafka得到确认。all表示需要收到所有ISR节点的确认信息，1表示只需要收到kafka leader的确认信息，0表示不需要任何确认信...
导读：随着业务的迅猛增长，Yandex.Metrica目前已经成为世界第三大Web流量分析平台，每天处理超过200亿个跟踪事件。能够拥有如此惊人的体量，在它背后...
canal 由Java开发，分为服务端和客户端，拥有众多的衍生应用，性能稳定，功能强大；canal 需要自己编写客户端来消费canal解析到的数据。
在 Flink 1.11 之前，Flink 使用的日志是 Log4j，配置文件 log4j.properties 中的内容如下：
分享嘉宾：董一峰,2016年加入字节跳动OLAP团队,一直从事大数据查询引擎的开发和推广工作,先后负责Hive,Spark,Durid,ClickHouse等大...
对于 SpringBootApplication 注解不在本文讲解，本文主要讲解一下 SpringApplication 类的 run 方法，这个 run 方...
问题导读 1.Barrier 对齐会造成什么问题？ 2.Barrier 对齐是否会造成反压？ 3.如何理解Unaligned Checkpoint ？ 作为...
柿子要挑软的捏，自然代码要先看少的 module。 统计了一下 (spring-boot-project) 各个模块源码行数：
fork 之后自己的仓库有一个 spring-boot 项目，地址是：https://github.com/zhisheng17/spring-boot.gi...
可以看见整体的结构目录是比较清晰的，主要源码模块分为 spring-boot-project 和 spring-boot-tests 两个，其中第一个是源码...
注：以下分析基于开源 v19.15.2.2-stable 版本进行，社区最新版本代码改动较大，但是总体思路是不变的。
为了解决上面2个问题，我们基于flink和drools规则引擎做了实时的日志处理服务。
在HTTPS出现之前，所有请求都是以明文方式送出的，那么如果有人在传输途中偷听或者抓包的话，你的所有通信内容都会泄漏。比较安全的方法是将通信内容加密在发送给对方...
扫码关注云+社区
领取腾讯云代金券
