|
18 | 18 | package org.apache.spark.sql.hive.thriftserver |
19 | 19 |
|
20 | 20 | import java.io._ |
21 | | -import java.util.{Locale, ArrayList => JArrayList} |
| 21 | +import java.util.{ArrayList => JArrayList, Locale} |
22 | 22 |
|
23 | 23 | import scala.collection.JavaConverters._ |
24 | | -import scala.util.control.NonFatal |
25 | 24 |
|
26 | 25 | import jline.console.ConsoleReader |
27 | 26 | import jline.console.history.FileHistory |
28 | 27 | import org.apache.commons.lang3.StringUtils |
29 | 28 | import org.apache.commons.logging.LogFactory |
30 | 29 | import org.apache.hadoop.conf.Configuration |
31 | | -import org.apache.hadoop.hdfs.security.token.delegation.DelegationTokenIdentifier |
32 | 30 | import org.apache.hadoop.hive.cli.{CliDriver, CliSessionState, OptionsProcessor} |
33 | 31 | import org.apache.hadoop.hive.common.{HiveInterruptCallback, HiveInterruptUtils} |
34 | 32 | import org.apache.hadoop.hive.conf.HiveConf |
35 | 33 | import org.apache.hadoop.hive.conf.HiveConf.ConfVars |
36 | 34 | import org.apache.hadoop.hive.ql.Driver |
37 | 35 | import org.apache.hadoop.hive.ql.exec.Utilities |
38 | | -import org.apache.hadoop.hive.ql.metadata.Hive |
39 | 36 | import org.apache.hadoop.hive.ql.processors._ |
40 | 37 | import org.apache.hadoop.hive.ql.session.SessionState |
41 | | -import org.apache.hadoop.io.Text |
42 | 38 | import org.apache.hadoop.security.UserGroupInformation |
43 | | -import org.apache.hadoop.security.token.Token |
44 | 39 | import org.apache.log4j.{Level, Logger} |
45 | 40 | import org.apache.thrift.transport.TSocket |
46 | | -import org.apache.spark.SparkConf |
47 | 41 |
|
| 42 | +import org.apache.spark.SparkConf |
48 | 43 | import org.apache.spark.deploy.SparkHadoopUtil |
49 | 44 | import org.apache.spark.deploy.security.HiveDelegationTokenProvider |
50 | 45 | import org.apache.spark.internal.Logging |
51 | 46 | import org.apache.spark.sql.AnalysisException |
52 | 47 | import org.apache.spark.sql.hive.HiveUtils |
53 | | -import org.apache.spark.util.{ShutdownHookManager, Utils} |
| 48 | +import org.apache.spark.util.ShutdownHookManager |
54 | 49 |
|
55 | 50 | /** |
56 | 51 | * This code doesn't support remote connections in Hive 1.2+, as the underlying CliDriver |
|
0 commit comments