包含标签：flink 的文章
-
【flink on yarn】/root/.flink/application_xxxxx/force-shading-1.9.1.jar does not exist
1.背景 启动脚本大致内容如下： 直接sh 执行这个脚本能正常拉起 但crontab -e配置这个脚本定时执行后报下面的错误： 2.原因分析 crontab 执行时没有加载到/……admin 2022-01-11
-
Flink(scala)整合MySQL统计UV(unique visitor)
数据源是尚硅谷的课件, 需要的话可以私信我 核心代码 import org.apache.flink.api.common.serialization.SimpleStringSchema import org.apache.flink.confi…… -
实时数仓与离线数仓架构对比、Flink消费流程
实时数仓架构图： 离线数仓： 与离线数仓区别： MySQL业务数据采集改用FlinkCDC;FlinkCDC与Maxwell处理方式和Cannal一样通过监控binlog方式（行级别），…… -
Flink使用KafkaSource从Kafka消息队列中读取数据
Flink使用KafkaSource从Kafka消息队列中读取数据 使用KafkaSource从Kafka消息队列中读取数据 1.KafkaSource创建的DataStream是一个并行的DataStream 2.KafkaS…… -
Flink 用户电商行为分析项目
Flink 用户电商行为分析 文章目录 Flink 用户电商行为分析 1. 实时统计分析 1. 1 热门商品统计 1. 2 热门页面统计 1. 3 网站uv统计 2. 业务流…… -
Flink使用local模式执行Flink程序，并且开启Flink的webUI
Flink使用local模式执行Flink程序，并且开启Flink的webUI 使用local模式执行Flink程序，并且开启Flink的webUI 1.在pom.xml中引入依赖 org.apache.flink flin…… -
doris 15 详细docker 编译 以及drois-flink的编译
1. 编译对应的版本 https://doris.apache.org/master/zh-CN/installing/compilation.html 这里选择 docker15 编译 2.docker 拉去镜像 [[email protected] ~]# d…… -
Flink自定义Sink将数据存到MySQL
如有更佳的保存MySQL方法 欢迎私信或留言分享 相互学习~ import org.apache.flink.streaming.api.functions.sink.RichSinkFunction // 自定义Sink dataStre…… -
Flink基于集合的Source2
Flink基于集合的Source2 基于集合的Source，该类Source通常就是为了做测试或实验的，不用于生产环境 fromElements创建的DataStream是一个有限的数据流，读取…… -
Flink基于集合的Source
Flink基于集合的Source 基于集合的Source，该类Source通常就是为了做测试或实验的，不用于生产环境 import org.apache.flink.streaming.api.datastream.DataS……