Fixed query to close when complete

kairosdb · Jan 3, 2018 · 8ced904 · 8ced904
1 parent 0bad93b
commit 8ced904
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 4 deletions.
diff --git a/pom.xml b/pom.xml
@@ -5,7 +5,7 @@
 	<groupId>org.kairosdb</groupId>
 	<artifactId>kairos-healthcheck</artifactId>
 	<!--<version>1.0-SNAPSHOT</version>-->
-	<version>1.0</version>
+	<version>1.1</version>
 	<packaging>jar</packaging>
 
 	<name>kairos-kafka</name>

diff --git a/src/main/java/org/kairosdb/plugin/health/DatastoreQueryHealthCheck.java b/src/main/java/org/kairosdb/plugin/health/DatastoreQueryHealthCheck.java
@@ -37,11 +37,12 @@ public String getName()
 	@Override
 	protected HealthCheck.Result check() throws Exception
 	{
+		DatastoreQuery query = null;
 		try
 		{
-			DatastoreQuery query = m_datastore.createQuery(
-					new QueryMetric(System.currentTimeMillis() - (10 * 60 * 1000),
-							0, m_healthMetric));
+			query = m_datastore.createQuery(
+				new QueryMetric(System.currentTimeMillis() - (10 * 60 * 1000),
+						0, m_healthMetric));
 
 			query.execute();
 			return HealthCheck.Result.healthy();
@@ -50,5 +51,10 @@ protected HealthCheck.Result check() throws Exception
 		{
 			return HealthCheck.Result.unhealthy(e);
 		}
+		finally
+		{
+			if (query != null)
+				query.close();
+		}
 	}
 }