fix 2

Author: aakash-db

sql/pipelines/src/main/scala/org/apache/spark/sql/pipelines/graph/FlowAnalysis.scala

@@ -24,7 +24,7 @@ import org.apache.spark.sql.catalyst.{AliasIdentifier, TableIdentifier}
 import org.apache.spark.sql.catalyst.analysis.{CTESubstitution, UnresolvedRelation}
 import org.apache.spark.sql.catalyst.plans.logical.{LogicalPlan, SubqueryAlias}
 import org.apache.spark.sql.classic.{DataFrame, Dataset, DataStreamReader, SparkSession}
-import org.apache.spark.sql.pipelines.{AnalysisWarning, Language}
+import org.apache.spark.sql.pipelines.AnalysisWarning
 import org.apache.spark.sql.pipelines.graph.GraphIdentifierManager.{ExternalDatasetIdentifier, InternalDatasetIdentifier}
 import org.apache.spark.sql.pipelines.util.{BatchReadOptions, InputReadOptions, StreamingReadOptions}
 

sql/pipelines/src/main/scala/org/apache/spark/sql/pipelines/graph/GraphErrors.scala

@@ -58,7 +58,8 @@ object GraphErrors {
   }
 
   /**
-   * Throws when a table path is unresolved, i.e. the table identifier does not exist in the catalog.
+   * Throws when a table path is unresolved, i.e. the table identifier
+   * does not exist in the catalog.
    *
    * @param identifier the unresolved table identifier
    */

sql/pipelines/src/main/scala/org/apache/spark/sql/pipelines/graph/QueryOrigin.scala

@@ -58,7 +58,6 @@ case class QueryOrigin(
       fileName = other.fileName.orElse(fileName),
       sqlText = other.sqlText.orElse(sqlText),
       line = other.line.orElse(line),
-      cellNumber = other.cellNumber.orElse(cellNumber),
       startPosition = other.startPosition.orElse(startPosition),
       objectType = other.objectType.orElse(objectType),
       objectName = other.objectName.orElse(objectName)

sql/pipelines/src/main/scala/org/apache/spark/sql/pipelines/util/InputReadInfo.scala

@@ -18,7 +18,6 @@
 package org.apache.spark.sql.pipelines.util
 
 import org.apache.spark.sql.catalyst.util.CaseInsensitiveMap
-import org.apache.spark.sql.pipelines.Language
 import org.apache.spark.sql.pipelines.util.StreamingReadOptions.EmptyUserOptions
 
 /**

sql/pipelines/src/test/scala/org/apache/spark/sql/pipelines/utils/PipelineTest.scala

@@ -17,17 +17,15 @@
 
 package org.apache.spark.sql.pipelines.utils
 
-import java.io.{BufferedReader, File, FileNotFoundException, InputStreamReader}
-import java.nio.file.{Files, Paths}
+import java.io.{BufferedReader, FileNotFoundException, InputStreamReader}
+import java.nio.file.Files
 
 import scala.collection.mutable.ArrayBuffer
-import scala.jdk.CollectionConverters._
 import scala.util.{Failure, Try}
 import scala.util.control.NonFatal
 
 import org.scalactic.source
 import org.scalatest.{BeforeAndAfterAll, BeforeAndAfterEach, Tag}
-import org.scalatest.exceptions.TestFailedDueToTimeoutException
 import org.scalatest.matchers.should.Matchers
 
 import org.apache.spark.{SparkConf, SparkFunSuite}
@@ -61,7 +59,7 @@ abstract class PipelineTest
    * all spark sessions created in tests.
    */
   protected def sparkConf: SparkConf = {
-    var conf = new SparkConf()
+    new SparkConf()
       .set("spark.sql.shuffle.partitions", "2")
       .set("spark.sql.session.timeZone", "UTC")
   }