src/main/java/org/embulk/input/gcs/GcsFileInputPlugin.java in embulk-input-gcs-0.2.1 vs src/main/java/org/embulk/input/gcs/GcsFileInputPlugin.java in embulk-input-gcs-0.2.2
- old
+ new
@@ -140,11 +140,13 @@
// list files recursively if path_prefix is specified
if (task.getPathPrefix().isPresent()) {
task.setFiles(listFiles(task, client));
}
- if (task.getFiles().isEmpty()) {
- throw new ConfigException("No file is found. Fix path_prefix or specify paths directly");
+ else {
+ if (task.getFiles().isEmpty()) {
+ throw new ConfigException("No file is found. Confirm paths option isn't empty");
+ }
}
// number of processors is same with number of files
return resume(task.dump(), task.getFiles().size(), control);
}