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

Reply via email to