This is an automated email from the ASF dual-hosted git repository.
tangyun 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 221777c0360 [hotfix] Fix incorrect JavaDoc for session window assigners
221777c0360 is described below
commit 221777c03607019a7a6b1fbf2dbce6d4484efbf3
Author: MUKUL GUPTA <[email protected]>
AuthorDate: Thu Feb 26 11:00:55 2026 +0530
[hotfix] Fix incorrect JavaDoc for session window assigners
Both EventTimeSessionWindows and ProcessingTimeSessionWindows had comments
incorrectly describing sliding window behavior ('every 10 seconds') instead
of session window behavior (inactivity gap). Updated to correctly describe
session windows with an inactivity gap.
---
.../streaming/api/windowing/assigners/EventTimeSessionWindows.java | 2 +-
.../streaming/api/windowing/assigners/ProcessingTimeSessionWindows.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git
a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/EventTimeSessionWindows.java
b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/EventTimeSessionWindows.java
index c03f5b589fb..e3ba69b798f 100644
---
a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/EventTimeSessionWindows.java
+++
b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/EventTimeSessionWindows.java
@@ -33,7 +33,7 @@ import java.util.Collections;
* A {@link WindowAssigner} that windows elements into sessions based on the
timestamp of the
* elements. Windows cannot overlap.
*
- * <p>For example, in order to window into windows of 1 minute, every 10
seconds:
+ * <p>For example, in order to window into windows(sessions) with an
inactivity gap of 1 minute:
*
* <pre>{@code
* DataStream<Tuple2<String, Integer>> in = ...;
diff --git
a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/ProcessingTimeSessionWindows.java
b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/ProcessingTimeSessionWindows.java
index 57588b44ecd..e19fb426d3c 100644
---
a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/ProcessingTimeSessionWindows.java
+++
b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/ProcessingTimeSessionWindows.java
@@ -33,7 +33,7 @@ import java.util.Collections;
* A {@link WindowAssigner} that windows elements into sessions based on the
current processing
* time. Windows cannot overlap.
*
- * <p>For example, in order to window into windows of 1 minute, every 10
seconds:
+ * <p>For example, in order to window into windows(sessions) with an
inactivity gap of 1 minute:
*
* <pre>{@code
* DataStream<Tuple2<String, Integer>> in = ...;