diff --git a/flink-filesystems/flink-s3-fs-base/src/main/java/org/apache/flink/fs/s3/common/FlinkS3FileSystem.java b/flink-filesystems/flink-s3-fs-base/src/main/java/org/apache/flink/fs/s3/common/FlinkS3FileSystem.java index 927eddf64ce17..af42482dcba84 100644 --- a/flink-filesystems/flink-s3-fs-base/src/main/java/org/apache/flink/fs/s3/common/FlinkS3FileSystem.java +++ b/flink-filesystems/flink-s3-fs-base/src/main/java/org/apache/flink/fs/s3/common/FlinkS3FileSystem.java @@ -285,7 +285,8 @@ public void copyFiles(List 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);