From 6631d8b00e8c5bafea15ea24415c5b55439193ee Mon Sep 17 00:00:00 2001
From: sangtran <tranquangsang12.7@gmail.com>
Date: Mon, 31 Aug 2026 23:51:37 +0700
Subject: bug: fix memory_state clear and guard window state empty with
 implement main.go for test

---
 core/operator/window.go | 4 ++++
 1 file changed, 4 insertions(+)

(limited to 'core/operator')

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 {
-- 
cgit v1.3.1