2022年6月 – 编程技术之美-IT之美

idea运行程序报错 java 程序包org.junit不存在

idea运行程序报错：java: 程序包org.junit不存在第一种可能，是你的pom中没有引入junit… 继续阅读 idea运行程序报错 java 程序包org.junit不存在

Flink Table & sql执行报错：原因是因为代码和pom引入的jar不一致。我当前测试代码… 继续阅读 Flink Table & sql执行报错：Make sure a planner module is on the classpath

侧流是什么，这个名字听起来有点奇怪，侧流的作用就是在主流处理过程中，再定义一个或多个输出流，输出一些额外的信息… 继续阅读 Flink从入门到实战七[ProcessFunction]-5-侧流输出

当有两条输入流输入数据，DataStream API提供了CoProcessFunction。CoProces… 继续阅读 Flink从入门到实战七[ProcessFunction]-4-CoProcessFunction使用

ProcessFunction中一个强大的功能就是定时器了。定时器可以支持我们设定在某个时间触发执行某些必要的… 继续阅读 Flink从入门到实战七[ProcessFunction]-3-Timer和TimerService

KeyedProcessFunction是在业务开发中应用最多的ProcessFunction，用在Keyed… 继续阅读 Flink从入门到实战七[ProcessFunction]-2-KeyedProcessFunction使用

Flink从较新的版本之后，API分为四层：1、SQL2、TABLE API3、DataSet/DataStr… 继续阅读 Flink从入门到实战七[ProcessFunction]-1-ProcessFunction是什么

Flink自带的Watermark类，最主要的就是BoundedOutOfOrdernessWatermark… 继续阅读 Flink从入门到实战六[Watermark]-5-Flink自带的Watermark

自定义 Watermark生成器，需要实现WatermarkGenerator接口。 watermark 的生… 继续阅读 Flink从入门到实战六[Watermark]-4-自定义Watermark

WatermarkStrategy 可以在 Flink 应用程序中的两处使用，第一种是直接在数据源上使用，第二… 继续阅读 Flink从入门到实战六[Watermark]-3-Watermark的使用

发表于2022年6月9日2023年7月22日作者 IT之美

前面的内容我们已经了解了Watermark是什么，简单来说Watermark就是用来解决乱序事件和迟到时间的一… 继续阅读 Flink从入门到实战六[Watermark]-2-Watermark API深入理解

发表于2022年6月7日2023年7月22日作者 IT之美

要了解Watermark，要先了解Flink中的时间语义，Flink中的时间分为三种：Event Time 事… 继续阅读 Flink从入门到实战六[Watermark]-1-Watermark是什么

发表于2022年6月5日2023年7月15日作者 IT之美

使用Flink的侧流创建Output，报错如下：原因在于代码中的OutputTag的定义有问题，代码如下：O… 继续阅读 OutputTag创建报错 Could not determine TypeInformation for the OutputTag type

发表于2022年6月3日2023年7月15日作者 IT之美

发表于2022年6月1日2023年7月15日作者 IT之美

Kafka启动报错： Kafka注册到Zookeeper，Zookeeper也报错： Kafka的错误已经比较… 继续阅读 Kafka启动报错：ERROR Error while loading log dir tmp kafka-logs