Merge pull request #933 from metamx/removeDeprecatedFiles

Update ForkingTaskRunner to remove @deprecated Files method usage
apache · Dec 4, 2014 · 6533de3 · 6533de3
2 parents 2681da4 + 325a5c4
commit 6533de3
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/indexing-service/src/main/java/io/druid/indexing/overlord/ForkingTaskRunner.java b/indexing-service/src/main/java/io/druid/indexing/overlord/ForkingTaskRunner.java
@@ -234,7 +234,7 @@ public TaskStatus call()
                             log.info("Logging task %s output to: %s", task.getId(), logFile);
                             boolean runFailed = true;
 
-                            try (final OutputStream toLogfile = Files.newOutputStreamSupplier(logFile).getOutput()) {
+                            try (final OutputStream toLogfile = Files.asByteSink(logFile).openBufferedStream()) {
                               ByteStreams.copy(processHolder.process.getInputStream(), toLogfile);
                               final int statusCode = processHolder.process.waitFor();
                               log.info("Process exited with status[%d] for task: %s", statusCode, task.getId());