Close the catalog after the test. Not really needed but nice to do (a…

…nd test).
uwescience · Jun 4, 2015 · 6780c98 · 6780c98
1 parent 7551d60
commit 6780c98
Show file tree

Hide file tree

Showing 2 changed files with 15 additions and 0 deletions.
diff --git a/test/edu/washington/escience/myria/coordinator/catalog/CatalogTest.java b/test/edu/washington/escience/myria/coordinator/catalog/CatalogTest.java
@@ -84,6 +84,8 @@ public void testCatalogCreation() throws CatalogException {
     for (final String worker : WORKERS) {
       assertTrue(values.contains(SocketInfo.valueOf(worker)));
     }
+
+    catalog.close();
   }
 
   /**
@@ -252,6 +254,8 @@ public void testCatalogQuerySearch() throws CatalogException {
     assertEquals(2, queries.size());
     assertEquals(Long.valueOf(3L), queries.get(0).queryId);
     assertEquals(Long.valueOf(2L), queries.get(1).queryId);
+
+    catalog.close();
   }
 
   /**
@@ -342,5 +346,7 @@ public void testCatalogExtraFieldsList() throws CatalogException {
     assertEquals(null, qs.logicalRa);
     assertEquals(ImmutableSet.copyOf(qs.profilingMode), ImmutableSet.copyOf(query.profilingMode));
     assertEquals(qs.language, query.language);
+
+    catalog.close();
   }
 }
diff --git a/test/edu/washington/escience/myria/operator/CatalogScanTest.java b/test/edu/washington/escience/myria/operator/CatalogScanTest.java
@@ -8,6 +8,7 @@
 import java.util.logging.Level;
 import java.util.logging.Logger;
 
+import org.junit.After;
 import org.junit.Before;
 import org.junit.Test;
 
@@ -48,6 +49,14 @@ public void setUp() throws Exception {
     catalog.newQuery(query);
   }
 
+  /**
+   * Destroy catalog.
+   */
+  @After
+  public void Cleanup() {
+    catalog.close();
+  }
+
   @Test
   public final void testQueryQueries() throws DbException, CatalogException {
     Schema schema = new Schema(ImmutableList.of(Type.LONG_TYPE, Type.STRING_TYPE), ImmutableList.of("id", "raw"));