[hotfix][table-runtime] Avoid NPE for SliceAssigner and improve error…

… message This closes apache#20302
zhuoluoy · Jul 19, 2022 · 180774e · 180774e
1 parent e54c864
commit 180774e
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/...src/main/java/org/apache/flink/table/runtime/operators/window/slicing/SliceAssigners.java b/...src/main/java/org/apache/flink/table/runtime/operators/window/slicing/SliceAssigners.java
@@ -553,6 +553,11 @@ protected AbstractSliceAssigner(int rowtimeIndex, ZoneId shiftTimeZone) {
         public final long assignSliceEnd(RowData element, ClockService clock) {
             final long timestamp;
             if (rowtimeIndex >= 0) {
+                if (element.isNullAt(rowtimeIndex)) {
+                    throw new RuntimeException(
+                            "RowTime field should not be null,"
+                                    + " please convert it to a non-null long value.");
+                }
                 // Precision for row timestamp is always 3
                 TimestampData rowTime = element.getTimestamp(rowtimeIndex, 3);
                 timestamp = toUtcTimestampMills(rowTime.getMillisecond(), shiftTimeZone);