Hi Ted,
validate() is supposed to throw runtime exception (IllegalStateException,
RuntimeException, ...) to "traverse" the executor.
Regards
JB
On 03/21/2017 01:56 AM, Ted Yu wrote:
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
--
Jean-Baptiste Onofré
jbono...@apache.org
http://blog.nanthrax.net
Talend - http://www.talend.com