Skip to content

Commit

Permalink
Fixing flaky test -
Browse files Browse the repository at this point in the history
The `SchedulerPoolTest` requires a separate scheduler configuration file
which need to be set at the time of starting the SparkContext. Hence,
stopping the SparkContext (if started by previously run suite) before
running this test to force create new SparkContext with configuration
set with correct scheduler pool config file.
  • Loading branch information
Vatsal Mevada committed Oct 18, 2019
1 parent a71bd34 commit 329c9f8
Showing 1 changed file with 1 addition and 0 deletions.
Expand Up @@ -39,6 +39,7 @@ class SchedulerPoolTest extends SnappyFunSuite with BeforeAndAfter with BeforeAn

override def beforeAll() {
super.beforeAll()
sc.stop()
kafkaTestUtils = new KafkaTestUtils
kafkaTestUtils.setup()
}
Expand Down

0 comments on commit 329c9f8

Please sign in to comment.