[hotfix] Log batch size in FlinkS3FileSystem instead of total

rkhachatryan · Nov 15, 2024 · 6d3b6fe · 6d3b6fe
1 parent 77e7ac0
commit 6d3b6fe
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...stems/flink-s3-fs-base/src/main/java/org/apache/flink/fs/s3/common/FlinkS3FileSystem.java b/...stems/flink-s3-fs-base/src/main/java/org/apache/flink/fs/s3/common/FlinkS3FileSystem.java
@@ -285,7 +285,8 @@ public void copyFiles(List<CopyRequest> requests, ICloseableRegistry closeableRe
                     || runningSizeFiles >= s5CmdConfiguration.maxBatchSizeFiles
                     || i == requests.size() - 1) {
                 LOG.info(
-                        "Copy {} files using s5cmd, total size: {}, args: {}",
+                        "Copy {} files out of {} using s5cmd, total size: {}, args: {}",
+                        batch.size(),
                         requests.size(),
                         runningSizeBytes,
                         artefacts);