flinkDemo完整代码scala版，包含TableApi，Flink Sql，DataStream ，socket、kafka、mysql数据源，

flink连接doris的驱动doris-flink-1.0-SNAPSHOT.jar，flink版本1.13.3 scala版本2.12，注意版本对应关系

flink1.14.0与hadoop3.x的兼容包，放在flink的lib目录下

基于Flink+ClickHouse构建亿级电商全端用户画像平台视频教程

透过源码看懂Flink核心框架的执行流程.pdf透过源码看懂Flink核心框架的执行流程.pdf

狄杰修改的flink-format-json，用于将聚合结果写入kafka 狄杰修改的flink-format-json，用于将聚合结果写入kafka 狄杰修改的flink-format-json，用于将聚合结果写入kafka

CDH6配置Flink1.12.0(编译安装)

Big Whale 巨鲸任务调度平台为美柚大数据研发的分布式计算任务调度系统，提供Spark、Flink等批处理任务的DAG调度和流处理任务的运行管理和状态监控，并具有Yarn应用管理、重复应用检测、大内存应用检测等功能。 服务基于Spring Boot 2.0开发，打包后即可运行。 概述 1.架构图 2.特性 基于SSH的脚本执行机制，部署简单快捷，仅需单个服务 基于Yarn Rest Api的任务状态同步机制，对Spark、Flink无版本限制 支持分布式 支持失败重试 支持任务依赖 支持复杂任务编排（DAG） 支持流处理任务运行管理和监控 支持Yarn应用管理 部署 1.准备 Java 1.8+ Mysql 5.1.0+ 下载项目或git clone项目 为解决 github README.md 图片无法正常加载的问题，请在hosts文件中加入相关域名解析规则，参考： 2.安装 创建

该项目是基于于flink的电商用户行为数据分析的flink项目，模块划为为：从项目介绍与代码框架、实时热门商品统计、替换kafka源、实时流量统计、恶意登录检测、恶意登录监控CEP实现、订单支付监控CEP实现

给大家分享一套课程——基于Flink+Hudi构建企业万亿级云上实时数据湖视频教程（2021新课）本课程基于真实的企业数据湖案例进行讲解，结合业务实现数据湖平台，让大家在实践中理解和掌握数据湖技术，未来数据湖的需求也会不断加大，希望同学们抓住这个机遇。 项目中将以热门的互联网电商业务场景为案例讲解，具体分析指标包含：流量分析，订单分析，用户行为分析，营销分析，广告分析等，能承载海量数据的实时分析，数据分析涵盖全端（PC、移动、小程序）应用。