Retry with exponential backoff

civitaspo · civitaspo · commit f9c0d88929d3 · 2015-12-28T12:44:28.000+09:00
diff --git a/src/main/java/org/embulk/output/sftp/SftpFileOutput.java b/src/main/java/org/embulk/output/sftp/SftpFileOutput.java
@@ -218,7 +218,7 @@ private FileObject newSftpFile(URI sftpUri)
                 logger.warn("failed to connect sftp server: " + e.getMessage(), e);
 
                 try {
-                    Thread.sleep(count * 1000); // milliseconds
+                    Thread.sleep(((long) Math.pow(2, count) * 1000)); // milliseconds
                 }
                 catch (InterruptedException e1) {
                     // Ignore this exception

Original file line number	Diff line number	Diff line change
`@@ -218,7 +218,7 @@ private FileObject newSftpFile(URI sftpUri)`
`218`	`218`	`logger.warn("failed to connect sftp server: " + e.getMessage(), e);`
`219`	`219`
`220`	`220`	`try {`
`221`		`- Thread.sleep(count * 1000); // milliseconds`
	`221`	`+ Thread.sleep(((long) Math.pow(2, count) * 1000)); // milliseconds`
`222`	`222`	`}`
`223`	`223`	`catch (InterruptedException e1) {`
`224`	`224`	`// Ignore this exception`