活动
flinkcdc+hudi0.10+hive(自动同步分区+压缩)
flinkcdc+hudi0.10+hive(自动同步分区+压缩)
flink提交任务的时候出现无法分配资源的问题
flink提交任务的时候出现无法分配资源的问题
不使用flink这类框架，如何自己实现分布式流数据处理
同事用flink写的服务，wifi和人关联查询，一个wifi数据kafka流，一个人的数据kafka流，按WIFI相机的设备号和时间关联查询，最后结果写入ClickHouse，如果不用flink这类框架，我想了一个实现分布式流处理的方法，代码写起来比用flink可能会繁琐一些，但应该也能做到可靠和高效。
Flink 算子简介
Flink的API层级 为流式/批式处理应用程序的开发提供了不同级别的抽象
Flink简介以及运行架构
Apache Flink 是一个框架和分布式处理引擎，用于在无边界和有边界数据流上进行有状态的计算
准备数据集用于flink学习
准备数据集用于flink学习
IDEA上运行Flink任务
IDEA上运行Flink任务
Apache Flink 如何应对Log4j最近爆出的”核弹级“漏洞？！
Apache Flink 如何应对Log4j最近爆出的”核弹级“漏洞？！
flink窗口函数之processWindowFucntion
前面学习了reduceFunction 和aggregateFunction 现在来学习processFunction 两者的区别是什么
flink之timeWindow与watermark详解
话不多说直接上代码 注意上面参数 1、timeWindow(Time.seconds(5)）开窗长度5s 2、new Bounded
flink之keyby groupby区别
之前学习spark 的时候对rdd和ds经常用的groupby操作，在flink中居然变少了 取而代之的是keyby 顾名思义，keyb
flink窗口函数之reduceFuction学习
注意源码注意，reduce就是combine两个value成为一个value，注意类型是一样的， 特性是 流式函数中数据是连绵
flink获取kafka的key value timestamp header
flink获取kafka的key value timestamp header
flink案例之统计每隔一段时间内url的访问量
需求：每隔10s统计每个url的访问量。 需求分析 1.每隔10s 那么需要开窗 2.每个url 需要key by 3.统计访问量 需要
flink案例之求TopN
需求：每隔2s 求之前10s内的url的访问量topN 需求分析： 1.隔2s 算10s 滑动窗口 2. topN分成两部分看，
flink遇到的问题
1.测试flink sql的时候 Exception in thread "main" org.apache.flink
flink启动报错Failed to construct kafka producer
flink local模式下启动 sink2kafka报错，具体报错如下 提取报错信息 Failed to construct kaf
flink写入到kafka 大坑解析。
1.kafka能不能发送null消息？ 能！ 2 flink能不能发送null消息到kafka？ 不能！ 这里就
Flink测试kafka数据写入和打印出
Flink测试kafka数据写入和打印出
apache flink docker-compose 运行试用
apache flink docker-compose 运行试用apache 是一个流处理框架，官方提供了docker 镜像，同时也提供了基于docker-compose 运行的说明docker-compose file运行效果编写简单jo
热门文章
flink java旁路输出(Side Output)，对原始流进行分流、复制
2023-04-18 14:15:57
apache flink docker-compose 运行试用
2023-05-12 07:20:32
java Flink滚动时间窗口聚合TumblingProcessingTimeWindows运算例子
2023-04-19 09:22:11
Flink java模拟生成自定义流式数据
2023-04-18 14:15:57
Flink测试kafka数据写入和打印出
2023-05-30 07:51:14
flinkcdc+hudi0.10+hive(自动同步分区+压缩)
2024-09-25 10:14:48
- APP
