[FLINK-4631] NullPointerException during stream task cleanup

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.1.2
• Fix Version/s: 1.2.0

Environment

Ubuntu server 12.04.5 64 bit
java version "1.8.0_40"
Java(TM) SE Runtime Environment (build 1.8.0_40-b26)
Java HotSpot(TM) 64-Bit Server VM (build 25.40-b25, mixed mode)

• Assignee: Unassigned
• Reporter: Avihai Berkovitz
• Created: 18/Sep/16 14:51
• Updated: 15/Dec/16 15:31
• Resolved: 12/Dec/16 19:13

Description

If a streaming job failed during startup (in my case, due to lack of network buffers), all the tasks are being cancelled before they started. This causes many instances of the following exception:

2016-09-18 14:17:12,177 ERROR org.apache.flink.streaming.runtime.tasks.StreamTask           - Error during cleanup of stream task
java.lang.NullPointerException
	at org.apache.flink.streaming.runtime.tasks.OneInputStreamTask.cleanup(OneInputStreamTask.java:73)
	at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:323)
	at org.apache.flink.runtime.taskmanager.Task.run(Task.java:584)
	at java.lang.Thread.run(Thread.java:745)

Issue Links

• links to: GitHub Pull Request #2709
• links to: GitHub Pull Request #2782
• links to: GitHub Pull Request #2807
• links to: GitHub Pull Request #2849