(flink) branch master updated: [FLINK-40949][table-runtime] Update `UnsliceAssigners` `NULL` window exception message

[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 fa25d7d1459 [FLINK-40949][table-runtime] Update `UnsliceAssigners` 
`NULL` window exception message
fa25d7d1459 is described below

commit fa25d7d1459190d1f9f653311f4bf7b2d45fbbb0
Author: Yahya Kisana <39938170+ykis...@users.noreply.github.com>
AuthorDate: Sun Oct 25 07:56:48 2026 -0600

    [FLINK-40949][table-runtime] Update `UnsliceAssigners` `NULL` window 
exception message
---
 .../table/runtime/operators/window/tvf/unslicing/UnsliceAssigners.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/window/tvf/unslicing/UnsliceAssigners.java
 
b/flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/window/tvf/unslicing/UnsliceAssigners.java
index a7030220ea2..2ecbda054db 100644
--- 
a/flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/window/tvf/unslicing/UnsliceAssigners.java
+++ 
b/flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/window/tvf/unslicing/UnsliceAssigners.java
@@ -229,7 +229,7 @@ public class UnsliceAssigners {
 
         private TimeWindow createWindow(RowData element) {
             if (element.isNullAt(windowStartIndex) || 
element.isNullAt(windowEndIndex)) {
-                throw new RuntimeException("RowTime field should not be 
null.");
+                throw new RuntimeException("Both window start and window end 
should not be null.");
             }
             // Precision for row timestamp is always 3
             final long windowStartTime = 
element.getTimestamp(windowStartIndex, 3).getMillisecond();