close JDBC connections (apache#12494)

aditya0811 · Feb 26, 2024 · a1ed8bd · a1ed8bd
1 parent dcbaca1
commit a1ed8bd
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/...tests/src/test/java/org/apache/pinot/integration/tests/OfflineClusterIntegrationTest.java b/...tests/src/test/java/org/apache/pinot/integration/tests/OfflineClusterIntegrationTest.java
@@ -3195,12 +3195,16 @@ public void testJDBCClient()
     ResultSet resultSet = statement.executeQuery(query);
     resultSet.first();
     Assert.assertTrue(resultSet.getLong(1) > 0);
+    connection.close();
+    Assert.assertTrue(connection.isClosed());
 
     connection = getJDBCConnectionFromBrokers(RANDOM.nextInt(), getRandomBrokerPort());
     statement = connection.createStatement();
     resultSet = statement.executeQuery(query);
     resultSet.first();
     Assert.assertTrue(resultSet.getLong(1) > 0);
+    connection.close();
+    Assert.assertTrue(connection.isClosed());
   }
 
   private java.sql.Connection getJDBCConnectionFromController(int controllerPort)