Revert "[SPARK-48139][CONNECT][TESTS] Try stabilising multi-thread tests in CI"

This reverts commit bb8b691.

Author: dongjoon-hyun

connector/connect/client/jvm/src/test/scala/org/apache/spark/sql/SparkSessionE2ESuite.scala

@@ -16,7 +16,7 @@
  */
 package org.apache.spark.sql
 
-import java.util.concurrent.Executors
+import java.util.concurrent.ForkJoinPool
 
 import scala.collection.mutable
 import scala.concurrent.{ExecutionContext, ExecutionContextExecutor, Future}
@@ -137,14 +137,15 @@ class SparkSessionE2ESuite extends ConnectFunSuite with RemoteSparkSession {
     assert(interrupted.length == 2, s"Interrupted operations: $interrupted.")
   }
 
-  test("interrupt tag") {
+  // TODO(SPARK-48139): Re-enable `SparkSessionE2ESuite.interrupt tag`
+  ignore("interrupt tag") {
     val session = spark
     import session.implicits._
 
     // global ExecutionContext has only 2 threads in Apache Spark CI
     // create own thread pool for four Futures used in this test
     val numThreads = 4
-    val fpool = Executors.newFixedThreadPool(numThreads)
+    val fpool = new ForkJoinPool(numThreads)
     val executionContext = ExecutionContext.fromExecutorService(fpool)
 
     val q1 = Future {

core/src/test/scala/org/apache/spark/JobCancellationSuite.scala

@@ -17,7 +17,7 @@
 
 package org.apache.spark
 
-import java.util.concurrent.{Executors, Semaphore, TimeUnit}
+import java.util.concurrent.{Semaphore, TimeUnit}
 import java.util.concurrent.atomic.AtomicInteger
 
 import scala.collection.mutable.ArrayBuffer
@@ -302,7 +302,7 @@ class JobCancellationSuite extends SparkFunSuite with Matchers with BeforeAndAft
     // global ExecutionContext has only 2 threads in Apache Spark CI
     // create own thread pool for four Futures used in this test
     val numThreads = 4
-    val fpool = Executors.newFixedThreadPool(numThreads)
+    val fpool = ThreadUtils.newForkJoinPool("job-tags-test-thread-pool", numThreads)
     val executionContext = ExecutionContext.fromExecutorService(fpool)
 
     try {

sql/core/src/test/scala/org/apache/spark/sql/SparkSessionJobTaggingAndCancellationSuite.scala

@@ -17,7 +17,7 @@
 
 package org.apache.spark.sql
 
-import java.util.concurrent.{ConcurrentHashMap, Executors, Semaphore, TimeUnit}
+import java.util.concurrent.{ConcurrentHashMap, Semaphore, TimeUnit}
 import java.util.concurrent.atomic.AtomicInteger
 
 import scala.concurrent.{ExecutionContext, Future}
@@ -121,7 +121,7 @@ class SparkSessionJobTaggingAndCancellationSuite
     // global ExecutionContext has only 2 threads in Apache Spark CI
     // create own thread pool for four Futures used in this test
     val numThreads = 3
-    val fpool = Executors.newFixedThreadPool(numThreads)
+    val fpool = ThreadUtils.newForkJoinPool("job-tags-test-thread-pool", numThreads)
     val executionContext = ExecutionContext.fromExecutorService(fpool)
 
     try {