This is an automated email from the ASF dual-hosted git repository.
ethanfeng pushed a commit to branch CELEBORN-287
in repository https://gitbox.apache.org/repos/asf/incubator-celeborn.git
The following commit(s) were added to refs/heads/CELEBORN-287 by this push:
new 1d78c960 address comments.
1d78c960 is described below
commit 1d78c960ce8f4ccfbd2dece9a16cb741d8f588cb
Author: Ethan Feng <[email protected]>
AuthorDate: Wed Feb 15 18:48:16 2023 +0800
address comments.
---
.../src/main/scala/com/aliyun/emr/rss/common/util/ThreadUtils.scala | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git
a/common/src/main/scala/com/aliyun/emr/rss/common/util/ThreadUtils.scala
b/common/src/main/scala/com/aliyun/emr/rss/common/util/ThreadUtils.scala
index 441efe98..813dab47 100644
--- a/common/src/main/scala/com/aliyun/emr/rss/common/util/ThreadUtils.scala
+++ b/common/src/main/scala/com/aliyun/emr/rss/common/util/ThreadUtils.scala
@@ -17,7 +17,9 @@
package com.aliyun.emr.rss.common.util
+import java.lang.Thread.UncaughtExceptionHandler
import java.util.concurrent._
+
import scala.collection.TraversableLike
import scala.collection.generic.CanBuildFrom
import scala.concurrent.{Awaitable, ExecutionContext,
ExecutionContextExecutor, Future}
@@ -28,8 +30,6 @@ import scala.util.control.NonFatal
import com.google.common.util.concurrent.{MoreExecutors, ThreadFactoryBuilder}
import com.aliyun.emr.rss.common.exception.RssException
-import java.lang.Thread.UncaughtExceptionHandler
-
object ThreadUtils {
private val sameThreadExecutionContext =