引入依赖并行度Parallelism 与Slot开窗Window引入依赖flink-javaflink-clientflink-streaming-java并行度Parallelism 与Slotparallelism path 三个地方可以设置应用程序代码页面设置 task slot设置standalone模式,需要一直等待足够的slot满足并行度parallelism 开窗Window 按每日进行聚合当日的起点当日的数据 偏移量偏移方式