Hi,
I was reading HDFSFileSource.java where:
@Override
public void validate() {
...
} catch (IOException | InterruptedException e) {
throw new RuntimeException(e);
}Why is validate() not declared to throw any exception ? If validation doesn't pass, there is nothing to clean up ? Thanks
