基于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。

登录可以使用的更多功能哦! 登录
作者榜
...
资讯小助手

资讯同步

...
内容小助手

文章同步

...
Deephub

公众号:deephub-imba

...
奕凯

公众号:奕凯的技术栈