diff options
| author | sangtran <tranquangsang12.7@gmail.com> | 2026-08-31 23:51:37 +0700 |
|---|---|---|
| committer | sangtran <tranquangsang12.7@gmail.com> | 2026-08-31 23:51:37 +0700 |
| commit | 6631d8b00e8c5bafea15ea24415c5b55439193ee (patch) | |
| tree | a320af141ba14bb02c669dbccbf00bcc850c6dbb /core/operator | |
| parent | 96c07bab1086510a55a004e9a1b90c30bc723a5c (diff) | |
| signature | Verified sangtran <tranquangsang12.7@gmail.com> Key: 8DD79823D235E1BB ultimate trust | |
| download | flux-6631d8b00e8c5bafea15ea24415c5b55439193ee.tar.gz flux-6631d8b00e8c5bafea15ea24415c5b55439193ee.zip | |
Verified bug: fix memory_state clear and guard window state empty with implement main.go for test
Diffstat (limited to 'core/operator')
| -rw-r--r-- | core/operator/window.go | 4 |
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 | |||
| 79 | return err | 79 | return err |
| 80 | } | 80 | } |
| 81 | 81 | ||
| 82 | if len(currentWindowState) == 0 { | ||
| 83 | continue | ||
| 84 | } | ||
| 85 | |||
| 82 | // NOTE: this is workaround create inline window, refactor later | 86 | // NOTE: this is workaround create inline window, refactor later |
| 83 | 87 | ||
| 84 | if err := o.userfunc.Apply(ctx, timer.Key, timer.Namespace.(core.Window), currentWindowState, out); err != nil { | 88 | if err := o.userfunc.Apply(ctx, timer.Key, timer.Namespace.(core.Window), currentWindowState, out); err != nil { |