Re: [PR] [CELEBORN-1317][FOLLOWUP] Fix threadDump UT stuck issue [celeborn]

["turboFei (via GitHub)" <gi...@apache.org>]

turboFei commented on code in PR #2429:
URL: https://github.com/apache/celeborn/pull/2429#discussion_r1542396203


##########
worker/src/test/scala/org/apache/celeborn/service/deploy/worker/http/api/ApiWorkerResourceSuite.scala:
##########
@@ -19,27 +19,30 @@ package org.apache.celeborn.service.deploy.worker.http.api
 
 import javax.ws.rs.core.MediaType
 
+import org.apache.celeborn.common.CelebornConf
+import org.apache.celeborn.common.util.{CelebornExitKind, Utils}
 import org.apache.celeborn.server.common.HttpService
 import org.apache.celeborn.server.common.http.ApiBaseResourceSuite
-import org.apache.celeborn.service.deploy.MiniClusterFeature
-import org.apache.celeborn.service.deploy.worker.Worker
+import org.apache.celeborn.service.deploy.worker.{Worker, WorkerArguments}
 
-class ApiWorkerResourceSuite extends ApiBaseResourceSuite with MiniClusterFeature {
+class ApiWorkerResourceSuite extends ApiBaseResourceSuite {
   private var worker: Worker = _
   override protected def httpService: HttpService = worker
 
   override def beforeAll(): Unit = {
-    logInfo("test initialized, setup celeborn mini cluster")
-    val (_, w) =
-      setupMiniClusterWithRandomPorts(workerConf = celebornConf.getAll.toMap, workerNum = 1)
-    worker = w.head
+    celebornConf.set(CelebornConf.WORKER_HTTP_PORT.key, s"${Utils.selectRandomPort(1024, 65535)}")
+    val workerArgs = new WorkerArguments(Array(), celebornConf)
+    worker = new Worker(celebornConf, workerArgs)
+    worker.metricsSystem.start()
+    worker.startHttpServer()
     super.beforeAll()

Review Comment:
   setup worker http server only instead of MiniCluster



-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: issues-unsubscribe@celeborn.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org