[jira] [Commented] (FLINK-31840) NullPointerException in operators.window.slicing.SliceAssigners$AbstractSliceAssigner.assignSliceEnd
[
https://issues.apache.org/jira/browse/FLINK-31840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17713599#comment-17713599
]
Robert Metzger commented on FLINK-31840:
Yeah, I wanted to mention the stack trace and fixed version somewhere, Jira is
ideal for that.
Ideally, your PR should have included a test case to make sure nobody is
breaking this in the future.
> 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
> Components: Table SQL / Runtime
>Reporter: Robert Metzger
>Assignee: lincoln lee
>Priority: Major
> Fix For: 1.16.0
>
>
> 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)
[jira] [Commented] (FLINK-31840) NullPointerException in operators.window.slicing.SliceAssigners$AbstractSliceAssigner.assignSliceEnd
[
https://issues.apache.org/jira/browse/FLINK-31840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17713577#comment-17713577
]
lincoln lee commented on FLINK-31840:
-
[~rmetzger]thanks for creating this ticket! Now the issue can be searched more
easily (it reminds me that it's really more important for users to create a
jira rather than just a hotfix of #20302)
> 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
>Priority: Major
> Fix For: 1.16.0
>
>
> 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)
[jira] [Commented] (FLINK-31840) NullPointerException in operators.window.slicing.SliceAssigners$AbstractSliceAssigner.assignSliceEnd
[
https://issues.apache.org/jira/browse/FLINK-31840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17713563#comment-17713563
]
Robert Metzger commented on FLINK-31840:
Note: I've filed this ticket just for tracking purposes, because I couldn't
find any information about this error on the internet. Now the problem and
solution is at least publicly available.
> 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
>Priority: Major
>
> 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)
[jira] [Commented] (FLINK-31840) NullPointerException in operators.window.slicing.SliceAssigners$AbstractSliceAssigner.assignSliceEnd
[
https://issues.apache.org/jira/browse/FLINK-31840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17713561#comment-17713561
]
Robert Metzger commented on FLINK-31840:
This issue was fixed in https://github.com/apache/flink/pull/20302/files
> 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
>Priority: Major
>
> 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)
