Apache
/
druid
mirror of https://github.com/apache/druid.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Reduce logging in RetryableS3OutputStream (#16853) 

This PR reduces logging in RetryableS3OutputStream.
This commit is contained in:
Akshat Jain 2024-08-08 10:42:40 +05:30 committed by GitHub
parent 408702e100
commit 7f67d26dfa
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 1 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
extensions-core/s3-extensions/src/main/java/org/apache/druid/storage/s3/output/RetryableS3OutputStream.java
View File

@ -212,11 +212,10 @@ public class RetryableS3OutputStream extends OutputStream
// Closeables are closed in LIFO order // Closeables are closed in LIFO order
closer.register(() -> { closer.register(() -> {
org.apache.commons.io.FileUtils.forceDelete(chunkStorePath); org.apache.commons.io.FileUtils.forceDelete(chunkStorePath);
LOG.info("Deleted chunkStorePath[%s]", chunkStorePath);
final long totalBytesUploaded = (currentChunk.id - 1) * chunkSize + currentChunk.length(); final long totalBytesUploaded = (currentChunk.id - 1) * chunkSize + currentChunk.length();
final long totalUploadTimeMillis = pushStopwatch.elapsed(TimeUnit.MILLISECONDS); final long totalUploadTimeMillis = pushStopwatch.elapsed(TimeUnit.MILLISECONDS);
LOG.info( LOG.debug(
"Pushed total [%d] parts containing [%d] bytes in [%d]ms for s3Key[%s], uploadId[%s].", "Pushed total [%d] parts containing [%d] bytes in [%d]ms for s3Key[%s], uploadId[%s].",
futures.size(), futures.size(),
totalBytesUploaded, totalBytesUploaded,