[jira] [Created] (FLINK-4742) NPE in WindowOperator.trigger() on shutdown

[Shang Yuanchun (Jira)]

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)