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 = ...;

Reply via email to