理解Flink之一编译Flink-1.11.1
下载源码 git clone -b release-1.11.1 https://github.com/apache/flink.git --depth=1 flink-1.11.1 编译 mvn clean install -DskipTests -Dhadoop.version ...
原文：Flink1.11.1-SQL空闲状态保留时间实现原理
. Flink SQL空闲状态保留时间和参数配置 Flink SQL 空闲状态保留时间是针对 SQL 中聚合 Key 而言的，空闲的时间也就是 Key 没有更新的时间。如果在 Flink SQL 任务中设置了空闲状态的保留时间，那么当状态空闲超过一定的时间后，状态就会被清理。 设置 Flink SQL 空闲状态保留时间有两个参数，状态空闲最小保留时间和状态空闲最大保留时间，很多人会问，为什么会设 ...
2020-10-15 23:21 0 670 推荐指数：
相关推荐
Flink WaterMark原理与实现
一、WaterMark作用 在使用 EventTime 处理 Stream 数据的时候会遇到数据乱序的问题，流处理从 Event(事 件)产生，流经 Source，再到 Operator，这中间需要一定的时间。虽然大部分情况下，传输到 Operator 的数据都是按照事件 ...
flink1.11.1，全新的table api
最新在自学flink，直接上的最新版，学到了table api，发现flink1.11/.1版本和flink1.10.1版本有很大差别。因为是新版本目前网上资料也不多，我通过查阅官网和自己编码运行，简单写了个demo分享和讲解一下。 新api提供的TableEnvironment接口 ...
windows server -为处于活动状态但空闲的终端服务会话指定时间限制
https://zhidao.baidu.com/question/109335687.html ...
Flink Table&Sql 时间特性
1、时间特性 2、处理时间（Processing Time） 3、事件时间（Event Time） ...
查看MySQL 连接信息--连接空闲时间及正在执行的SQL
MySQL 客户端与MySQL server建立连接后，就可以执行SQL语句了。 如何查看一个连接上是否正在执行SQL语句，或者连接是否处于空闲呢？ 下面我们做下测试。 1.查看连接的空闲时间 首先看下测试程序。 代码中，每3s执行一条sql语句。 启动程序，输出结果如 ...
49-flink sql时间函数实现每周某几天和某些天的指定时间段条件
业务：指定窗口时间，统计每周一到周五，凌晨00点到早上八点的事件条数，超过N次触发输出结果 事件时间格式：yyyy-MM-dd HH:mm:ss.SSS,字段名ts 使用到的函数：DAYOFWEEK(timestamp timestamp)，DATE_FORMAT(date,pattern ...
FLINK重点原理与机制：状态（3）两阶段提交
假设一种场景，从Kafka Source拉取数据，经过一次窗口聚合，最后将数据发送到Kafka Sink，如下图：1.JobManager向Source发送Barrier，开始进入pre-Commit阶段，当只有内部状态时，pre-commit阶段无需执行额外的操作，仅仅是写入一些已定义的状态 ...