Try sleeping to ensure sessions are released (#314)

vertica · Feb 11, 2022 · e42db8d · e42db8d
1 parent cd86d87
commit e42db8d
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/functional-tests/src/main/scala/com/vertica/spark/functests/EndToEndTests.scala b/functional-tests/src/main/scala/com/vertica/spark/functests/EndToEndTests.scala
@@ -4145,6 +4145,8 @@ class EndToEndTests(readOpts: Map[String, String], writeOpts: Map[String, String
       val dfRead: DataFrame = spark.read.format("com.vertica.spark.datasource.VerticaSource").options(readOpts + ("table" -> tableName)).load()
       assert(dfRead.count() == 3)
     }
+    // Ensure operations have time to complete and cleanup
+    Thread.sleep(2000)
 
     val stmt = conn.createStatement()
     val query = "SELECT COUNT(*) FROM v_monitor.sessions;"