Flink“Time Window”操作不为PublicPlacesFromKafka示例文件生成输出

Question

...
// find popular places
val popularSpots = rides
  // match ride to grid cell and event type (start or end)
  .map(new GridCellMatcher)
  // partition by cell id and event type
  .keyBy( k => k )
  // build sliding window
  .timeWindow(Time.minutes(15), Time.minutes(5))
  // count events in window
  .apply{ (key: (Int, Boolean), window, vals, out: Collector[(Int, Long, Boolean, Int)]) =>
    out.collect( (key._1, window.getEnd, key._2, vals.size) )
  }

// print result on stdout
    popularSpots.print()
...

Answer 1

您是否为源配置了适当的加速比？默认情况下（没有加速系数），源模拟原始数据，即它以与原始生成的记录相同的速率发出记录。这意味着生产1分钟的数据需要1分钟。

window运算符每5分钟聚合一次最后15分钟的数据。因此，窗口操作符产生第一个结果需要5分钟的时间。

如果您将加速系数设置为600，您将在1秒内获得10分钟的数据。