Github user kumarvishal09 commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/2195#discussion_r183056905
--- Diff:
integration/spark-common-test/src/test/scala/org/apache/carbondata/integration/spark/testsuite/preaggregate/TestPreAggCreateCommand.scala
---
@@ -454,8 +454,8 @@ class TestPreAggCreateCommand extends QueryTest with
BeforeAndAfterAll {
.stripMargin))
i = i + 1
}
- executorService.invokeAll(tasks)
-
+ val futures = executorService.invokeAll(tasks).asScala
+ futures.foreach(_.get())
checkExistence(sql("show tables"), true, "agg_concu1", "tbl_concurr")
executorService.shutdown()
--- End diff --
use executorService.awaitTermination(2, TimeUnit.Hour);
---
