Robert Metzger created FLINK-31840: -------------------------------------- Summary: NullPointerException in operators.window.slicing.SliceAssigners$AbstractSliceAssigner.assignSliceEnd Key: FLINK-31840 URL: https://issues.apache.org/jira/browse/FLINK-31840 Project: Flink Issue Type: Bug Reporter: Robert Metzger
While running a Flink SQL Query (with a hop window), I got this error. {code} Caused by: org.apache.flink.streaming.runtime.tasks.ExceptionInChainedOperatorException: Could not forward element to next operator at org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.pushToOperator(CopyingChainingOutput.java:99) at org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.collect(CopyingChainingOutput.java:57) at org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.collect(CopyingChainingOutput.java:29) at org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:56) at org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:29) at StreamExecCalc$11.processElement(Unknown Source) at org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.pushToOperator(CopyingChainingOutput.java:82) ... 23 more Caused by: java.lang.NullPointerException at org.apache.flink.table.runtime.operators.window.slicing.SliceAssigners$AbstractSliceAssigner.assignSliceEnd(SliceAssigners.java:558) at org.apache.flink.table.runtime.operators.aggregate.window.LocalSlicingWindowAggOperator.processElement(LocalSlicingWindowAggOperator.java:114) at org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.pushToOperator(CopyingChainingOutput.java:82) ... 29 more {code} It was caused by a timestamp field containing NULL values. -- This message was sent by Atlassian Jira (v8.20.10#820010)