Skip to content

Commit 6eb9ab1

Browse files
committed
Compile fix + removed couple of unused imports
1 parent 69646eb commit 6eb9ab1

File tree

3 files changed

+1
-3
lines changed

3 files changed

+1
-3
lines changed

core/src/test/scala/org/apache/spark/deploy/security/HadoopDelegationTokenManagerSuite.scala

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,6 @@
1818
package org.apache.spark.deploy.security
1919

2020
import org.apache.hadoop.conf.Configuration
21-
import org.apache.hadoop.fs.FileSystem
2221
import org.apache.hadoop.security.Credentials
2322

2423
import org.apache.spark.{SparkConf, SparkFunSuite}

external/kafka-0-10-token-provider/src/main/scala/org/apache/spark/kafka010/KafkaDelegationTokenProvider.scala

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,6 @@ import scala.language.existentials
2121
import scala.util.control.NonFatal
2222

2323
import org.apache.hadoop.conf.Configuration
24-
import org.apache.hadoop.fs.FileSystem
2524
import org.apache.hadoop.security.Credentials
2625
import org.apache.kafka.common.security.auth.SecurityProtocol.{SASL_PLAINTEXT, SASL_SSL, SSL}
2726

sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/SparkSQLCLIDriver.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -126,7 +126,7 @@ private[hive] object SparkSQLCLIDriver extends Logging {
126126
val tokenProvider = new HiveDelegationTokenProvider()
127127
if (tokenProvider.delegationTokensRequired(sparkConf, hadoopConf)) {
128128
val credentials = new Credentials()
129-
tokenProvider.obtainDelegationTokens(hadoopConf, sparkConf, Set.empty, credentials)
129+
tokenProvider.obtainDelegationTokens(hadoopConf, sparkConf, credentials)
130130
UserGroupInformation.getCurrentUser.addCredentials(credentials)
131131
}
132132

0 commit comments

Comments
 (0)