diff --git a/modules/transformer-kinesis/src/main/scala/com/snowplowanalytics/snowplow/rdbloader/transformer/kinesis/sinks/generic/Record.scala b/modules/transformer-kinesis/src/main/scala/com/snowplowanalytics/snowplow/rdbloader/transformer/kinesis/sinks/generic/Record.scala
index ec9a32396..155c9e01b 100644
--- a/modules/transformer-kinesis/src/main/scala/com/snowplowanalytics/snowplow/rdbloader/transformer/kinesis/sinks/generic/Record.scala
+++ b/modules/transformer-kinesis/src/main/scala/com/snowplowanalytics/snowplow/rdbloader/transformer/kinesis/sinks/generic/Record.scala
@@ -84,7 +84,8 @@ case object EndWindow extends Record[Nothing, Nothing, Nothing]
               // Same window, drop Left(w)
               go(Some(w), tail, emptyWindow)
             case Some(_) if emptyWindow =>
-                Pull.pure(())
+              // New window, but nothing to emit
+              go(Some(w), tail, true)
             case Some(_) =>
               Pull.output1[F, Record[W, A, S]](Record.EndWindow) *>
                 go(Some(w), tail, true)