You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@celeborn.apache.org by et...@apache.org on 2023/02/15 10:48:26 UTC
[incubator-celeborn] branch CELEBORN-287 updated: address comments.
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 <et...@apache.org>
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 =