[FLINK-10663] Closing StreamingFileSink can cause NPE

• Type: Bug
• Status: Closed
• Priority: Critical
• Resolution: Fixed
• Affects Version/s: 1.6.1, 1.7.0
• Fix Version/s: 1.6.3, 1.7.0
• Component/s: Connectors / Common, Connectors / FileSystem
• Labels: pull-request-available

Environment

Rev cb141940821bcf62f4102dfd5c76aff99d0c15d1

• Assignee: Gary Yao
• Reporter: Gary Yao
• Created: 24/Oct/18 08:34
• Updated: 25/Oct/18 11:57
• Resolved: 25/Oct/18 11:57

Description

Description
If the sink is closed before it's state is initialized, an NPE is thrown.

Stacktrace

java.lang.NullPointerException
	at org.apache.flink.streaming.api.functions.sink.filesystem.StreamingFileSink.close(StreamingFileSink.java:378)
	at org.apache.flink.api.common.functions.util.FunctionUtils.closeFunction(FunctionUtils.java:43)
	at org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.dispose(AbstractUdfStreamOperator.java:117)
	at org.apache.flink.streaming.runtime.tasks.StreamTask.disposeAllOperators(StreamTask.java:477)
	at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:378)
	at org.apache.flink.runtime.taskmanager.Task.run(Task.java:704)
	at java.lang.Thread.run(Thread.java:748)

Issue Links

• is related to: FLINK-10357 Streaming File Sink end-to-end test failed with mismatch
• links to: GitHub Pull Request #6915