File tree Expand file tree Collapse file tree 2 files changed +3
-5
lines changed
src/main/java/org/embulk/output Expand file tree Collapse file tree 2 files changed +3
-5
lines changed Original file line number Diff line number Diff line change @@ -278,9 +278,7 @@ public ConfigDiff transaction(
278278 s3SecretAccessKey .orElse (null ))) {
279279 String tmpDir = System .getProperty ("java.io.tmpdir" , "/tmp" );
280280 File logDir = new File (tmpDir );
281- File [] logFiles =
282- logDir .listFiles (
283- (dir , name ) -> name .startsWith ("snowflake_jdbc" ));
281+ File [] logFiles = logDir .listFiles ((dir , name ) -> name .startsWith ("snowflake_jdbc" ));
284282 if (logFiles != null && logFiles .length > 0 ) {
285283 Optional <File > latest =
286284 Arrays .stream (logFiles ).max (Comparator .comparingLong (File ::lastModified ));
Original file line number Diff line number Diff line change @@ -55,7 +55,7 @@ public void uploadIfExists(File file) {
5555 String timestamp = LocalDateTime .now ().format (DateTimeFormatter .ofPattern ("yyyyMMdd_HHmmss" ));
5656 String originalFileName = file .getName ();
5757 String fileNameWithTimestamp ;
58-
58+
5959 // Insert timestamp before file extension
6060 int lastDotIndex = originalFileName .lastIndexOf ('.' );
6161 if (lastDotIndex > 0 ) {
@@ -65,7 +65,7 @@ public void uploadIfExists(File file) {
6565 } else {
6666 fileNameWithTimestamp = originalFileName + "_" + timestamp ;
6767 }
68-
68+
6969 String key = prefix .isEmpty () ? fileNameWithTimestamp : prefix + "/" + fileNameWithTimestamp ;
7070 try {
7171 PutObjectRequest putObjectRequest =
You can’t perform that action at this time.
0 commit comments