You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Matt Zimmer (JIRA)" <ji...@apache.org> on 2016/10/05 02:24:20 UTC
[jira] [Created] (FLINK-4742) NPE in WindowOperator.trigger() on
shutdown
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)