Github user vanzin commented on a diff in the pull request: https://github.com/apache/spark/pull/19893#discussion_r155609975 --- Diff: core/src/test/scala/org/apache/spark/SparkFunSuite.scala --- @@ -34,12 +36,53 @@ abstract class SparkFunSuite with Logging { // scalastyle:on + val threadWhiteList = Set( + /** + * Netty related threads. + */ + "netty.*", + + /** + * A Single-thread singleton EventExecutor inside netty which creates such threads. + */ + "globalEventExecutor.*", + + /** + * Netty creates such threads. + * Checks if a thread is alive periodically and runs a task when a thread dies. + */ + "threadDeathWatcher.*", + + /** + * These threads are created by spark when internal RPC environment initialized and later used. --- End diff -- `TaskSetManagerSuite` extends `LocalSparkContext` which stops contexts in its `afterEach` method, so if the context is not being stopped, or the threads are not being stopped, there's an issue somewhere.
--- --------------------------------------------------------------------- To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org For additional commands, e-mail: reviews-h...@spark.apache.org