1 files changed, 4 insertions, 0 deletions

diff --git a/core/operator/window.go b/core/operator/window.go
index 610f6e3..3f75d60 100644
--- a/core/operator/window.go
+++ b/core/operator/window.go
@@ -79,6 +79,10 @@ func (o *WindowOperator[IN, OUT]) Process(ctx context.Context, record core.Strea
                                 return err
                         }
 
+                        if len(currentWindowState) == 0 {
+                                continue
+                        }
+
                         // NOTE: this is workaround create inline window, refactor later
 
                         if err := o.userfunc.Apply(ctx, timer.Key, timer.Namespace.(core.Window), currentWindowState, out); err != nil {