From bd91a404919d0e2a9c025db8e69a7f7e02f49732 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Xavier=20L=C3=A9aut=C3=A9?= Date: Sat, 13 Dec 2014 15:22:55 -0800 Subject: [PATCH] fix task log streaming --- .../io/druid/indexing/overlord/http/OverlordResource.java | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/indexing-service/src/main/java/io/druid/indexing/overlord/http/OverlordResource.java b/indexing-service/src/main/java/io/druid/indexing/overlord/http/OverlordResource.java index 050a5620856..76523504f53 100644 --- a/indexing-service/src/main/java/io/druid/indexing/overlord/http/OverlordResource.java +++ b/indexing-service/src/main/java/io/druid/indexing/overlord/http/OverlordResource.java @@ -412,9 +412,7 @@ public class OverlordResource try { final Optional stream = taskLogStreamer.streamTaskLog(taskid, offset); if (stream.isPresent()) { - try(InputStream istream = stream.get().openStream()) { - return Response.ok(istream).build(); - } + return Response.ok(stream.get().openStream()).build(); } else { return Response.status(Response.Status.NOT_FOUND) .entity(