IP属地:广东
前言 工作当中我们往往会遇到这样的需求场景:某张表中不同的统计指标,需要从多个不同的 kafka 数据源当中统计。这种做法,我们很容易想到把多个...
在流计算中,事件会持续不断的产生,如果每次计算都是相互独立的,不依赖于上下游事件,则称为无状态 (stateless) 计算;如果每次的计算依赖...
Checkpointing 是 Flink 故障恢复的内部机制。一个 checkpoint 就是 Flink应用程序产生的状态的一个副本。如果 ...
环境准备 安装Docker for Windows安装方法可以参考Docker官方文档[https://docs.docker.com/dock...
前言: Flink从1.10开始支持从canal或者debezium消费binlog数据,从而实现数据的同步;但是无论是canal和debezi...
前言: Flink最近刚发布了1.11.0版本,由于加了很多新的功能,对sql的支持更加全面,我就迫不及待的在本地运行了个demo,但是运行的时...
前言:在做flink实时计算平台的时候,我遇到过这样一个问题,在执行sql任务的时候,我们需要预先创建一些Table,View,甚至是funct...
Streaming Processing Concepts(流处理基本概念) Bounded and UnBounded Data and Pr...