diff --git a/extensions-core/hdfs-storage/src/main/java/io/druid/storage/hdfs/tasklog/HdfsTaskLogs.java b/extensions-core/hdfs-storage/src/main/java/io/druid/storage/hdfs/tasklog/HdfsTaskLogs.java index f438b664367..e539aaba994 100644 --- a/extensions-core/hdfs-storage/src/main/java/io/druid/storage/hdfs/tasklog/HdfsTaskLogs.java +++ b/extensions-core/hdfs-storage/src/main/java/io/druid/storage/hdfs/tasklog/HdfsTaskLogs.java @@ -66,8 +66,9 @@ public class HdfsTaskLogs implements TaskLogs final OutputStream out = fs.create(path, true) ) { ByteStreams.copy(in, out); - log.info("Wrote task log to: %s", path); } + + log.info("Wrote task log to: %s", path); } @Override