diff --git a/gluten-core/src/main/scala/io/glutenproject/GlutenPlugin.scala b/gluten-core/src/main/scala/io/glutenproject/GlutenPlugin.scala index 4c56ce3126b4..69e85ecb98e5 100644 --- a/gluten-core/src/main/scala/io/glutenproject/GlutenPlugin.scala +++ b/gluten-core/src/main/scala/io/glutenproject/GlutenPlugin.scala @@ -40,7 +40,9 @@ import org.apache.spark.util.{SparkResourceUtil, TaskResources} import java.util import java.util.{Collections, Objects} -import scala.collection.{immutable, mutable} +import scala.collection.compat._ +import scala.collection.compat.immutable.ArraySeq +import scala.collection.mutable import scala.language.implicitConversions class GlutenPlugin extends SparkPlugin { @@ -191,7 +193,7 @@ private[glutenproject] class GlutenDriverPlugin extends DriverPlugin with Loggin private[glutenproject] class GlutenExecutorPlugin extends ExecutorPlugin { private var executorEndpoint: GlutenExecutorEndpoint = _ private val taskListeners: Seq[TaskListener] = - (immutable.ArraySeq.unsafeWrapArray(Array(TaskResources))) + (ArraySeq.unsafeWrapArray(Array(TaskResources))) /** Initialize the executor plugin. */ override def init(ctx: PluginContext, extraConf: util.Map[String, String]): Unit = {