From 07522c0ebbd89d57131026952f9e8ac587560822 Mon Sep 17 00:00:00 2001 From: angerszhu Date: Thu, 8 Aug 2019 20:04:28 +0800 Subject: [PATCH] fix scala style --- core/src/main/scala/org/apache/spark/executor/Executor.scala | 3 +-- .../spark/sql/hive/thriftserver/SparkSQLSessionManager.scala | 4 ++-- 2 files changed, 3 insertions(+), 4 deletions(-) diff --git a/core/src/main/scala/org/apache/spark/executor/Executor.scala b/core/src/main/scala/org/apache/spark/executor/Executor.scala index 3938a00d2650e..6ca5f85c2ca96 100644 --- a/core/src/main/scala/org/apache/spark/executor/Executor.scala +++ b/core/src/main/scala/org/apache/spark/executor/Executor.scala @@ -33,10 +33,9 @@ import scala.concurrent.duration._ import scala.util.control.NonFatal import com.google.common.util.concurrent.ThreadFactoryBuilder - import org.apache.hadoop.io.Text -import org.apache.hadoop.security.token.Token import org.apache.hadoop.security.{Credentials, UserGroupInformation} +import org.apache.hadoop.security.token.Token import org.apache.spark._ import org.apache.spark.deploy.SparkHadoopUtil diff --git a/sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/SparkSQLSessionManager.scala b/sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/SparkSQLSessionManager.scala index 94016ff0bfae3..ddb4983876566 100644 --- a/sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/SparkSQLSessionManager.scala +++ b/sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/SparkSQLSessionManager.scala @@ -17,6 +17,8 @@ package org.apache.spark.sql.hive.thriftserver +import scala.collection.JavaConverters._ + import org.apache.hadoop.hive.conf.HiveConf import org.apache.hadoop.security.Credentials import org.apache.hive.service.cli.{HiveSQLException, SessionHandle} @@ -31,8 +33,6 @@ import org.apache.spark.sql.hive.thriftserver.ReflectionUtils._ import org.apache.spark.sql.hive.thriftserver.server.SparkSQLOperationManager import org.apache.spark.sql.hive.thriftserver.util.{ThriftServerHadoopUtils, ThriftServerHDFSDelegationTokenProvider} -import scala.collection.JavaConverters._ - private[hive] class SparkSQLSessionManager(hiveServer: HiveServer2, sqlContext: SQLContext) extends SessionManager(hiveServer) with ReflectedCompositeService