环境 ubuntu14、flink1.7.2、scala2.11、kafka2.3.0、jdk1.8、idea2019 步骤 抽取出业务时间戳，告诉 Flink 框架基于业务时间做窗口 过滤出点击行为(pv)数目 按一小时的窗口大小，每 5 分钟统计一次，做滑动窗口聚合(Sliding Window) 按每个窗口聚合，输出每个窗口中点击量前 N 名的商品 实现 创建maven项目，命名UserBehaviorAnalysis，其pom内容如下： 4.0.0 com.us