(flink) branch master updated: [FLINK-37510] Avoid duplicate calculations for SlidingEventTimeWindows

[snuyanzin]

This is an automated email from the ASF dual-hosted git repository.

snuyanzin pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new f1c362d47df [FLINK-37510] Avoid duplicate calculations for 
SlidingEventTimeWindows
f1c362d47df is described below

commit f1c362d47df1f6c15c4c8e131d1cf3e62c89f340
Author: Jiaan Geng <belie...@163.com>
AuthorDate: Tue Apr 28 15:37:07 2026 +0800

    [FLINK-37510] Avoid duplicate calculations for SlidingEventTimeWindows
---
 .../streaming/api/windowing/assigners/SlidingEventTimeWindows.java   | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git 
a/flink-runtime/src/main/java/org/apache/flink/streaming/api/windowing/assigners/SlidingEventTimeWindows.java
 
b/flink-runtime/src/main/java/org/apache/flink/streaming/api/windowing/assigners/SlidingEventTimeWindows.java
index 666a65a108d..edb40c9c94d 100644
--- 
a/flink-runtime/src/main/java/org/apache/flink/streaming/api/windowing/assigners/SlidingEventTimeWindows.java
+++ 
b/flink-runtime/src/main/java/org/apache/flink/streaming/api/windowing/assigners/SlidingEventTimeWindows.java
@@ -78,8 +78,9 @@ public class SlidingEventTimeWindows extends 
WindowAssigner<Object, TimeWindow>
             Object element, long timestamp, WindowAssignerContext context) {
         if (timestamp > Long.MIN_VALUE) {
             List<TimeWindow> windows = new ArrayList<>((int) (size / slide));
-            long lastStart = TimeWindow.getWindowStartWithOffset(timestamp, 
offset, slide);
-            for (long start = lastStart; start > timestamp - size; start -= 
slide) {
+            final long lastStart = 
TimeWindow.getWindowStartWithOffset(timestamp, offset, slide);
+            final long lower = timestamp - size;
+            for (long start = lastStart; start > lower; start -= slide) {
                 windows.add(new TimeWindow(start, start + size));
             }
             return windows;