连续两个窗口，第二个窗口一直无法被触发，单独跑第一个窗口没有问题，其实就是想模拟一个当天的topN

val stream: DataStream[PageView] = env.addSource(new PVSource()).map(node => { Event(node._1, node.2.toString, 1) }) .assignTimestampsAndWatermarks(new BoundedOutOfOrdernessTimestampExtractorEvent { override def extractTimestamp(element: Event): Long = { element.createTime.toLong } }) .keyBy(.id) .window(TumblingEventTimeWindows.of(Time.days(1), Time.hours(-8))) .trigger(ContinuousEventTimeTrigger.of(Time.seconds(3))) .aggregate(new Agg(), new WfPV())

stream
   .windowAll(TumblingEventTimeWindows.of(Time.days(1), Time.hours(-8)))
  .trigger(ContinuousEventTimeTrigger.of(Time.seconds(3)))
  .process(new TopWindowAll(3))
  .print()

env.execute()