File tree Expand file tree Collapse file tree 1 file changed +0
-15
lines changed
src/main/java/org/embulk/output/sftp/utils Expand file tree Collapse file tree 1 file changed +0
-15
lines changed Original file line number Diff line number Diff line change 11package org .embulk .output .sftp .utils ;
22
3- import org .embulk .spi .Exec ;
4- import org .slf4j .Logger ;
5-
63import java .util .concurrent .Callable ;
74import java .util .concurrent .ExecutionException ;
85import java .util .concurrent .ExecutorService ;
1411public abstract class TimedCallable <V > implements Callable <V >
1512{
1613 private static final ExecutorService THREAD_POOL = Executors .newCachedThreadPool ();
17- private Logger logger = Exec .getLogger (getClass ());
18-
19- public V callNonInterruptible (long timeout , TimeUnit timeUnit )
20- {
21- try {
22- return call (timeout , timeUnit );
23- }
24- catch (Exception e ) {
25- logger .warn ("Time-out call failed, ignore and resume" , e );
26- return null ;
27- }
28- }
2914
3015 public V call (long timeout , TimeUnit timeUnit )
3116 throws InterruptedException , ExecutionException , TimeoutException
You can’t perform that action at this time.
0 commit comments