Details
-
Bug
-
Status: Closed
-
Critical
-
Resolution: Fixed
-
1.6.1, 1.7.0
-
Rev cb141940821bcf62f4102dfd5c76aff99d0c15d1
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)
Attachments
Issue Links
- is related to
-
FLINK-10357 Streaming File Sink end-to-end test failed with mismatch
-
- Closed
-
- links to