WatermarkStrategy 可以在 Flink 应用程序中的两处使用，第一种是直接在数据源上使用，第二… 继续阅读 Flink从入门到实战六[Watermark]-3-Watermark的使用
分类： Java之美
Flink从入门到实战六[Watermark]-2-Watermark API深入理解
前面的内容我们已经了解了Watermark是什么，简单来说Watermark就是用来解决乱序事件和迟到时间的一… 继续阅读 Flink从入门到实战六[Watermark]-2-Watermark API深入理解
Flink从入门到实战六[Watermark]-1-Watermark是什么
要了解Watermark，要先了解Flink中的时间语义，Flink中的时间分为三种：Event Time 事… 继续阅读 Flink从入门到实战六[Watermark]-1-Watermark是什么
OutputTag创建报错 Could not determine TypeInformation for the OutputTag type
使用Flink的侧流创建Output，报错如下： 原因在于代码中的OutputTag的定义有问题，代码如下：O… 继续阅读 OutputTag创建报错 Could not determine TypeInformation for the OutputTag type
执行数据库保存提示：Caused by：java.sql.SQLException：Access denied for user
程序连接mysql时，报错：Caused by: java.sql.SQLException: Access … 继续阅读 执行数据库保存提示：Caused by：java.sql.SQLException：Access denied for user
Kafka启动报错：ERROR Error while loading log dir tmp kafka-logs
Kafka启动报错： Kafka注册到Zookeeper，Zookeeper也报错： Kafka的错误已经比较… 继续阅读 Kafka启动报错：ERROR Error while loading log dir tmp kafka-logs
idea创建项目maven报错java.lang.NoSuchMethodError
idea创建项目maven报错： 问题原因：主要是因为idea和maven版本导致的，要么是idea版本过高，… 继续阅读 idea创建项目maven报错java.lang.NoSuchMethodError
Flink运行时报错：Caused by: org.apache.flink.runtime.JobException: Recovery is suppressed by NoRestartBackoffTimeStrategy
Flink运行时报错： 根本问题是版本问题，早期版本StreamExecutionEnvironment中默认… 继续阅读 Flink运行时报错：Caused by: org.apache.flink.runtime.JobException: Recovery is suppressed by NoRestartBackoffTimeStrategy
Git报错：fatal Unable to create xxx目录.git index.lock File exists
git执行add命令是报错： 最简单的处理就是重启电脑，因为你操作了两个git的工作空间，其中前一个git的线… 继续阅读 Git报错：fatal Unable to create xxx目录.git index.lock File exists
Flink从入门到实战五[Window]-13-Window Interval Join
Window Join按照窗口和相同的key进行两个流的合并，如果没有窗口，可以使用Interval Join… 继续阅读 Flink从入门到实战五[Window]-13-Window Interval Join
Flink从入门到实战五[Window]-12-Window Join
Window 还可以将两个流中的元素进行关联合并。官方解释：窗口连接将共享一个公共Key且位于同一窗口中的两个… 继续阅读 Flink从入门到实战五[Window]-12-Window Join
Flink从入门到实战五[Window]-11-Window Evictor
Window Evictor驱逐器（Evictor）能够在触发器触发之后，窗口函数开始计算之前或之后从窗口中清… 继续阅读 Flink从入门到实战五[Window]-11-Window Evictor
Flink从入门到实战五[Window]-10-Window Trigger
Window Trigger触发器（Trigger）决定了何时启动Window Function来处理窗口中的… 继续阅读 Flink从入门到实战五[Window]-10-Window Trigger
Flink从入门到实战五[Window]-9-Window 滑动计数窗口SlidingCountWindow
前面演示的Window都是基于时间的，我们再来看一个基于滑动计数的Window demo。demo实现的目标很… 继续阅读 Flink从入门到实战五[Window]-9-Window 滑动计数窗口SlidingCountWindow
Flink从入门到实战五[Window]-8-Window 滚动计数窗口TumblingCountWindow
前面演示的Window都是基于时间的，我们再来看一个基于滚动计数的Window demo。demo实现的目标很… 继续阅读 Flink从入门到实战五[Window]-8-Window 滚动计数窗口TumblingCountWindow
Flink从入门到实战五[Window]-7-ProcessWindowFunction基于AggregateFunction增量计算
ProcessWindowFunction是一个全量计算函数，也就是窗口内数据到达后不计算，而是等到窗口出发时… 继续阅读 Flink从入门到实战五[Window]-7-ProcessWindowFunction基于AggregateFunction增量计算
Flink从入门到实战五[Window]-6-ProcessWindowFunction基于RecuctFunction增量计算
ProcessWindowFunction是一个全量计算函数，也就是窗口内数据到达后不计算，而是等到窗口出发时… 继续阅读 Flink从入门到实战五[Window]-6-ProcessWindowFunction基于RecuctFunction增量计算
Flink从入门到实战五[Window]-5-Window Function ProcessWindowFunction
ProcessWindowFunction官方解释：A ProcessWindowFunction gets … 继续阅读 Flink从入门到实战五[Window]-5-Window Function ProcessWindowFunction
Flink从入门到实战五[Window]-4-Window Function AggregateFunction
AggregateFunction是一个功能加强的ReduceFunction，ReduceFunction只… 继续阅读 Flink从入门到实战五[Window]-4-Window Function AggregateFunction
Flink从入门到实战五[Window]-3-Window Function ReduceFunction
ReduceFunction能够指定两个元素如何合并生成一个元素，两个输入元素和最终输出元素的类型必须相同。R… 继续阅读 Flink从入门到实战五[Window]-3-Window Function ReduceFunction