[jira] [Created] (FLINK-7430) ContinuousFileReaderOperator swallows exceptions

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|  
Report Content as Inappropriate

[jira] [Created] (FLINK-7430) ContinuousFileReaderOperator swallows exceptions

JIRA jira@apache.org
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)
Loading...