Fix a small bug where an NPE can occur if a closeable is not present

jcodezone · Jan 17, 2015 · 52f65b1 · 52f65b1
1 parent 38c155e
commit 52f65b1
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/server/src/main/java/io/druid/segment/realtime/plumber/RealtimePlumber.java b/server/src/main/java/io/druid/segment/realtime/plumber/RealtimePlumber.java
@@ -288,7 +288,9 @@ public QueryRunner<T> apply(FireHydrant input)
                                             }
                                             finally {
                                               try {
-                                                closeable.close();
+                                                if (closeable != null) {
+                                                  closeable.close();
+                                                }
                                               }
                                               catch (IOException e) {
                                                 throw Throwables.propagate(e);