diff --git a/extensions/spark/kyuubi-spark-connector-yarn/src/main/scala/org/apache/kyuubi/spark/connector/yarn/YarnLogPartitionReader.scala b/extensions/spark/kyuubi-spark-connector-yarn/src/main/scala/org/apache/kyuubi/spark/connector/yarn/YarnLogPartitionReader.scala index 1a789c7a56c..cf33c81eebb 100644 --- a/extensions/spark/kyuubi-spark-connector-yarn/src/main/scala/org/apache/kyuubi/spark/connector/yarn/YarnLogPartitionReader.scala +++ b/extensions/spark/kyuubi-spark-connector-yarn/src/main/scala/org/apache/kyuubi/spark/connector/yarn/YarnLogPartitionReader.scala @@ -17,6 +17,11 @@ package org.apache.kyuubi.spark.connector.yarn +import java.io.{BufferedReader, InputStreamReader} + +import scala.collection.mutable.ArrayBuffer +import scala.util.matching.Regex + import org.apache.hadoop.conf.Configuration import org.apache.hadoop.fs.Path import org.apache.hadoop.io.IOUtils @@ -25,10 +30,6 @@ import org.apache.spark.sql.catalyst.expressions.GenericInternalRow import org.apache.spark.sql.connector.read.PartitionReader import org.apache.spark.unsafe.types.UTF8String -import java.io.{BufferedReader, InputStreamReader} -import scala.collection.mutable.ArrayBuffer -import scala.util.matching.Regex - class YarnLogPartitionReader(yarnLogPartition: YarnLogPartition) extends PartitionReader[InternalRow] {