Skip to content

Commit 9a1c987

Browse files
rkhachatryanpnowojski
authored andcommitted
[hotfix] Log batch size in FlinkS3FileSystem instead of total
1 parent 25b7292 commit 9a1c987

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

flink-filesystems/flink-s3-fs-base/src/main/java/org/apache/flink/fs/s3/common/FlinkS3FileSystem.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -285,7 +285,8 @@ public void copyFiles(List<CopyRequest> requests, ICloseableRegistry closeableRe
285285
|| runningSizeFiles >= s5CmdConfiguration.maxBatchSizeFiles
286286
|| i == requests.size() - 1) {
287287
LOG.info(
288-
"Copy {} files using s5cmd, total size: {}, args: {}",
288+
"Copy {} files out of {} using s5cmd, total size: {}, args: {}",
289+
batch.size(),
289290
requests.size(),
290291
runningSizeBytes,
291292
artefacts);

0 commit comments

Comments
 (0)