File tree Expand file tree Collapse file tree 1 file changed +9
-5
lines changed
src/main/java/org/embulk/output/sftp Expand file tree Collapse file tree 1 file changed +9
-5
lines changed Original file line number Diff line number Diff line change @@ -172,7 +172,7 @@ public Void execute() throws IOException
172172 try {
173173 withConnectionRetry (retriable );
174174 }
175- } catch (Exception e ) {
175+ catch (Exception e ) {
176176 throw (IOException )e ;
177177 }
178178 }
@@ -220,7 +220,8 @@ private void closeCurrentFile()
220220 currentFile .getContent ().close ();
221221 currentFile .close ();
222222 }
223- catch (IOException e ) {
223+ catch (FileSystemException e ) {
224+ IOException e ) {
224225 logger .error (e .getMessage ());
225226 Throwables .propagate (e );
226227 }
@@ -263,7 +264,8 @@ private <T> T withConnectionRetry( final Retriable<T> op ) throws Exception {
263264 while (true ) {
264265 try {
265266 return op .execute ();
266- } catch (final Exception e ) {
267+ }
268+ catch (final Exception e ) {
267269 if (++count > maxConnectionRetry ) {
268270 throw e ;
269271 }
@@ -302,7 +304,8 @@ public FileObject execute() throws FileSystemException
302304 };
303305 try {
304306 return withConnectionRetry (retriable );
305- } catch (Exception e ) {
307+ }
308+ catch (Exception e ) {
306309 throw (FileSystemException )e ;
307310 }
308311 }
@@ -318,7 +321,8 @@ public OutputStream execute() throws FileSystemException
318321 };
319322 try {
320323 return withConnectionRetry (retriable );
321- } catch (Exception e ) {
324+ }
325+ catch (Exception e ) {
322326 throw (FileSystemException )e ;
323327 }
324328 }
You can’t perform that action at this time.
0 commit comments