[
https://issues.apache.org/jira/browse/FLINK-5717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-5717:
----------------------------------
Labels: easyfix pull-request-available starter (was: easyfix starter)
> NPE on SessionWindows with ContinuousProcessingTimeTrigger
> ----------------------------------------------------------
>
> Key: FLINK-5717
> URL: https://issues.apache.org/jira/browse/FLINK-5717
> Project: Flink
> Issue Type: Bug
> Components: API / DataStream
> Affects Versions: 1.1.4, 1.2.0
> Reporter: Oriol Orellana
> Assignee: Lijie Wang
> Priority: Major
> Labels: easyfix, pull-request-available, starter
>
> The same bug as https://issues.apache.org/jira/browse/FLINK-4862, but for
> ContinuousProcessingTimeTrigger. I copied the description from that same
> issue.
> *what's the error?*
> The following NPE error is thrown when SessionWindows with
> ContinuousProcessingTimeTrigger is used.
> {code:borderStyle=solid}
> Caused by: java.lang.NullPointerException
> at
> org.apache.flink.streaming.api.windowing.triggers.ContinuousProcessingTimeTrigger.clear(ContinuousProcessingTimeTrigger.java:91)
> at
> org.apache.flink.streaming.runtime.operators.windowing.WindowOperator$Context.clear(WindowOperator.java:768)
> at
> org.apache.flink.streaming.runtime.operators.windowing.WindowOperator$2.merge(WindowOperator.java:310)
> at
> org.apache.flink.streaming.runtime.operators.windowing.WindowOperator$2.merge(WindowOperator.java:297)
> at
> org.apache.flink.streaming.runtime.operators.windowing.MergingWindowSet.addWindow(MergingWindowSet.java:196)
> at
> org.apache.flink.streaming.runtime.operators.windowing.WindowOperator.processElement(WindowOperator.java:297)
> at
> org.apache.flink.streaming.runtime.io.StreamInputProcessor.processInput(StreamInputProcessor.java:183)
> at
> org.apache.flink.streaming.runtime.tasks.OneInputStreamTask.run(OneInputStreamTask.java:66)
> at
> org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:271)
> at org.apache.flink.runtime.taskmanager.Task.run(Task.java:609)
> at java.lang.Thread.run(Thread.java:745)
> {code}
> *how to reproduce ?*
> use ContinuousProcessingTimeTrigger instead of the default EventTimeTrigger
> in SessionWindowing example.
> *what's the cause ?*
> When two session windows are being merged, the states of the two
> ContinuousProcessingTimeTrigger are merged as well and the new namespace is
> the merged window. Later when the context tries to delete Timer from the old
> trigger and looks up the timestamp by the old namespace, null value is
> returned.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
