一.问题描述 环境介绍:CDH 6.3.1集群Flink版本 1.9.0Kafka版本 2.12本地运行无问题，提交到yarn集群报错 代码: ...

一.问题描述 环境介绍Flink版本 1.9.0Kafka版本 2.12 代码: 运行报错java.lang.NoClassDefFoundEr...

一.项目概述 1.1 订单支付实时监控 基本需求 用户下单之后，应设置订单失效时间，以提高用户支付的意愿，并降 低系统风险 用户下单后15分钟未...

一. 项目概述   随着智能手机的普及，在如今的电商网站中已经有越来越多的用户来自移动端， 相比起传统浏览器的登录方式 ，手机 APP 成为了更...

一.项目概述 1.1 模块创建和数据准备   新建一个NetworkFlowAnalysis的package。   将 apache 服务器的...

一. 项目剖析 基本需求:统计近1小时内的热门商品，每5分钟更新一次热门度用浏览次数（“pv”）来衡量 解决思路在所有用户行为数据中，过滤出浏览...

一. 电商的用户行为   电商平台中的用户行为频繁且较复杂，系统上线运行一段时间后，可以收集到大量的用户行为数据， 进而利用大数据技术进行深入挖...

一. Flink CDC介绍 https://github.com/ververica/flink-cdc-connectors[https:/...