Я проверял функцию искрового окна, чтобы проверять попадание страницы в 30 секунд, но он продолжал добавлять значение предыдущего времени окна.
предположим, в **12:00:30 count is 10** и **12:01:00 count is 10**.
Но искра дает **output as 20**
Добавление предыдущего значения окна. Я использую Kafka-spark Streaming.
val rs=words.reduceByKeyAndWindow((x,y)=>(x._1 + y._1,x._2 + y._2),Durations.seconds(30))
Пожалуйста, помогите, и как я могу сбросить значение, как переворот окна работает в KSQL Kafka.