Skip to content
Permalink
Browse files

[#1177] Throw exception if file not found (#1178)

fixes #1177
  • Loading branch information...
timo95 authored and galpha committed Mar 7, 2019
1 parent f602c62 commit 47488e061f38c0be6c3d1f2b183005b08addd636
@@ -28,6 +28,7 @@
import org.gradoop.flink.util.GradoopFlinkConfig;

import java.io.BufferedReader;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.io.InputStreamReader;
import java.nio.charset.Charset;
@@ -103,7 +104,7 @@ public CSVMetaData readLocal(String path, Configuration hdfsConfig) throws IOExc
Charset charset = Charset.forName("UTF-8");

if (!fs.exists(file)) {
return null;
throw new FileNotFoundException(path);
} else {

try (BufferedReader br = new BufferedReader(new InputStreamReader(fs.open(file), charset))) {

0 comments on commit 47488e0

Please sign in to comment.
You can’t perform that action at this time.
You signed in with another tab or window. Reload to refresh your session. You signed out in another tab or window. Reload to refresh your session.