Matt Zimmer created FLINK-4742:
----------------------------------
Summary: NPE in WindowOperator.trigger() on shutdown
Key: FLINK-4742
URL: https://issues.apache.org/jira/browse/FLINK-4742
Project: Flink
Issue Type: Bug
Components: Windowing Operators
Affects Versions: 1.2.0
Reporter: Matt Zimmer
Priority: Minor
We have a test that otherwise passed on our CI server, but failed with an NPE
on the line in {{WindowOperator#trigger()}} that removes an item from the
processing time queue (stack trace lined up with
{{processingTimeTimersQueue.remove();}}. Seems like a timing issue... Can
close or dispose be called in a shutdown thread while trigger is executing?
Unless we had a source/artifact mismatch, {{processingTimeTimersQueue.peek()}}
was called a few lines before successfully, so it appears
{{processingTimeTimersQueue}} was nulled out after.
Could not reproduce locally, so I couldn't validate that for certain.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
