spark streaming messages.reduceByKeyAndWindow 中的slideDuration设置参数问题

环境spark2.1.0, spark local 模式, 消费kafka中数据 steaming 运行间隔为 秒,  numsTuple 中的值都设置为"1"  
numsTuple.reduceByKeyAndWindow(
(x: Int, y /*这里 y 值故意都设置为 1 */: Int) => x + y, 
Seconds(5), 
Seconds(15)
)
newTuple.foreachRDD(rdd => {
  rdd.collect().foreach(x => {
    log.warn(s"=======================  ${x._1} : ${x._2}")
  })
})
//如果结果 x._2的所有值为 3 !!! 当把 slideDuration 的值设置为 10 秒时,对应的 x._2 也为 2! 这不应该都为1吗,并且是每隔10s 才以当前批次与前一批次的数据一起运算. 
窗口时间(windowDuration)设置的与 streaming 每一小批运行时间一样都为5秒,为什么会出现这样的问题呢???

要回复问题请先登录注册