基于flink与groovy实现全实时动态规则智能营销与风控系统
本文是对视频课程《基于flink与groovy实现亿用户级实时动态规则智能运营系统》的介绍说明;本项目极具行业实用价值,可为各企业开发人员提供系统设计思路与灵感,而且,它不光可用于智能运营,也可以应用在实时规则推荐,实时广告推送,实时规则封控,实时交通监控等纪委广泛的场景中;当然,各类培训机构学员也
Flink1.16集群安装部署
Flink1.16集群安装部署
Flink部署之Yarn
Flink部署之Yarn
FLINK 基于1.15.2的Java开发-连接kafka并把内容sink到redis
flink连接kafka并把相应的通过kafka输入的内容sink到redis
RocksDB基本架构与原理介绍
RocksdbFlink提供基于流的有状态计算,除了提供实时数据流的处理能力,还需要将计算产生的状态存储起来。为了满足状态存取需求,提供了memory、flie system、rocksdb三种类型的状态存储机制。memory存取高效单空间有限,且可用性低;file system提供状态持久化能力但
Flink:FlinkSql解析嵌套Json
flinksql解析嵌套json
flink执行环境和读取kafka以及自定义数据源操作
flink运行环境和加载数据源
基于Flink SQL CDC Mysql to Mysql数据同步
本方案使用FlinkSQL方法,同步两表中的数据。其中Flink应用可以部署在具有公网IP的服务器上,同时可以连接其他局域网中服务器的数据进行同步工作,如不需要操作管理页面,则不对服务器IP有要求。
springboot集成flink-cdc
springboot集成flink-cdc 实时变更捕获技术 监听数据库变化
zookeeper版本选择与配置参数调优
Apache ZooKeeper 如何选择,以及相关配置优化
flink常见故障排除
flink常见故障排除
面试系列-flink面试题(一)
30分钟的连环flink面试拷问
Flink双流join导致数据重复
大家都知道flink sql 中 left join 数据不会互相等待,存在 retract 问题,会导致写入 kafka 的数据量变大,就会导致出现数据重复的问题。:即常见的曝光日志流(show_log)通过 log_id 关联点击日志流(click_log),将数据的关联结果进行下发。执行sql
Flink CDC Oracle 完整踩坑指南
FlinkCDC完整踩坑指南
docker 搭建 flink 并上传任务
1.16.0-scala_2.12-java8 镜像版本说明,flink 1.16.0,flink 内置 scala 版本 2.12,Java 版本 8。如下两个容器启动成功,可以看到 web 端口为 18081,taskmanager 启动一个,包含 5 个任务槽。如下:注意运行需要设置启动参数
Flink高手之路:Flink的环境搭建
Flink高手之路:Flink的环境搭建
Flink 命令行参数介绍
Flink 命令行参数介绍Job Lifecycle Management | Job 生命周期管理Flink Run Command | flink run 命令参数选项Flink Run Command | 通用的参数选项Flink Run Command | yarn-cluster mod
数据库数据采集利器FlinkCDC
持续分享有用、有价值、精选的优质大数据干货致力于打造全网最优质的大数据专题
Flink MySQL CDC 使用总结
学习总结Flink MySQL CDC,主要目的是同步MySQL数据至其他数据源如Hudi、MySQL等,本文主要以 MySQL2Hudi、MySQL2MySQL两个场景进行示例验证。
大数据Flink进阶(十五):Flink On Yarn任务提交
Flink On Yarn任务提交支持Session会话模式、Per-Job单作业模式、Application应用模式。下面分别介绍这三种模式的任务提交命令和原理。为了能演示出不同模式的效果,这里我们编写准备Flink代码形成一个Flink Application,该代码中包含有2个job。