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