From 26e22b24d3d6d52dcc8dcf062eb365b30d5fda05 Mon Sep 17 00:00:00 2001 From: Andy Grove Date: Wed, 17 Jul 2024 12:00:18 -0600 Subject: [PATCH] format --- .../scala/org/apache/spark/sql/CometTPCQueryBase.scala | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/spark/src/test/scala/org/apache/spark/sql/CometTPCQueryBase.scala b/spark/src/test/scala/org/apache/spark/sql/CometTPCQueryBase.scala index 7b5bf7131..99f5f3f42 100644 --- a/spark/src/test/scala/org/apache/spark/sql/CometTPCQueryBase.scala +++ b/spark/src/test/scala/org/apache/spark/sql/CometTPCQueryBase.scala @@ -19,6 +19,8 @@ package org.apache.spark.sql +import java.io.{File, FileNotFoundException} + import scala.util.Try import org.apache.spark.SparkConf @@ -29,8 +31,6 @@ import org.apache.spark.sql.types.StructType import org.apache.comet.{CometConf, CometSparkSessionExtensions} -import java.io.{File, FileNotFoundException} - /** * Base trait for TPC related query execution */ @@ -81,7 +81,8 @@ trait CometTPCQueryBase extends Logging { } else if (new File(tableFilePathAlt).exists()) { tableFilePathAlt } else { - throw new FileNotFoundException(s"Table does not exist at $tableFilePathDefault or $tableFilePathAlt") + throw new FileNotFoundException( + s"Table does not exist at $tableFilePathDefault or $tableFilePathAlt") } if (createTempView) { cometSpark.read.parquet(tableFilePath).createOrReplaceTempView(tableName)