Peter Ertl created FLINK-7430: --------------------------------- Summary: ContinuousFileReaderOperator swallows exceptions Key: FLINK-7430 URL: https://issues.apache.org/jira/browse/FLINK-7430 Project: Flink Issue Type: Bug Components: DataStream API Affects Versions: 1.3.2 Reporter: Peter Ertl
The class ContinuousFileReaderOperator is swallowing exception as the following example demonstrated: package org.apache.flink.streaming.examples; import java.io.File; import java.io.IOException; import org.apache.flink.api.common.io.OutputFormat; import org.apache.flink.configuration.Configuration; import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment; public class FormatExceptionSwallowed { public static void main(String[] args) throws Exception { final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); File bla = File.createTempFile("foo", "baz"); env.readTextFile(bla.getCanonicalPath()) .writeUsingOutputFormat(new OutputFormat<String>() { @Override public void configure(final Configuration parameters) { } @Override public void open(final int taskNumber, final int numTasks) throws IOException { } @Override public void writeRecord(final String record) throws IOException { throw new IllegalArgumentException("bla"); } @Override public void close() throws IOException { } }); env.execute("go"); // JOB TERMINATES WITH NO EXCEPTION / ERROR whatsoever ... } } -- This message was sent by Atlassian JIRA (v6.4.14#64029)