fix NPE in DirectDruidClient

2013-11-20 17:15:26 -08:00 · 2013-11-20 17:15:26 -08:00 · 3134affac9
parent d0fe70a21f
commit 3134affac9
1 changed files with 3 additions and 1 deletions
--- a/server/src/main/java/io/druid/client/DirectDruidClient.java
+++ b/server/src/main/java/io/druid/client/DirectDruidClient.java
@ -292,7 +292,9 @@ public class DirectDruidClient<T> implements QueryRunner<T>
    @Override
    public void close() throws IOException
    {
+      if(jp != null) {
        jp.close();
      }
    }
+  }
 }