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 =