flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Oriol Orellana (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-5717) NPE on SessionWindows with ContinuousProcessingTimeTrigger
Date Mon, 06 Feb 2017 09:28:41 GMT
Oriol Orellana created FLINK-5717:
-------------------------------------

             Summary: NPE on SessionWindows with ContinuousProcessingTimeTrigger
                 Key: FLINK-5717
                 URL: https://issues.apache.org/jira/browse/FLINK-5717
             Project: Flink
          Issue Type: Bug
          Components: DataStream API
    Affects Versions: 1.1.4, 2.0.0
            Reporter: Oriol Orellana


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:borderStyle=solid}

*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 ContinuousEventTimeTrigger
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
(v6.3.15#6346)

Mime
View raw message