fix scala format

Signed-off-by: YANGDB <[email protected]>
opensearch-project · Oct 11, 2024 · 0875ed8 · 0875ed8
1 parent 3c86837
commit 0875ed8
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 15 deletions.
diff --git a/...test/src/integration/scala/org/opensearch/flint/spark/ppl/FlintSparkPPLBasicITSuite.scala b/...test/src/integration/scala/org/opensearch/flint/spark/ppl/FlintSparkPPLBasicITSuite.scala
@@ -26,7 +26,7 @@ class FlintSparkPPLBasicITSuite
   private val t2 = "`spark_catalog`.default.`flint_ppl_test2`"
   private val t3 = "spark_catalog.`default`.`flint_ppl_test3`"
   private val t4 = "`spark_catalog`.`default`.flint_ppl_test4"
-  
+
   override def beforeAll(): Unit = {
     super.beforeAll()
 
@@ -129,8 +129,7 @@ class FlintSparkPPLBasicITSuite
 
   test("test backtick table names and name contains '.'") {
     Seq(t1, t2, t3, t4).foreach { table =>
-      val frame = sql(
-        s"""
+      val frame = sql(s"""
            | source = $table| head 2
            | """.stripMargin)
       assert(frame.collect().length == 2)
@@ -139,24 +138,21 @@ class FlintSparkPPLBasicITSuite
     val t5 = "`spark_catalog`.default.`flint/ppl/test5.log`"
     val t6 = "spark_catalog.default.`flint_ppl_test6.log`"
     Seq(t5, t6).foreach { table =>
-      val ex = intercept[AnalysisException](sql(
-        s"""
+      val ex = intercept[AnalysisException](sql(s"""
            | source = $table| head 2
            | """.stripMargin))
       assert(ex.getMessage().contains("TABLE_OR_VIEW_NOT_FOUND"))
     }
     val t7 = "spark_catalog.default.flint_ppl_test7.log"
-    val ex = intercept[IllegalArgumentException](sql(
-      s"""
+    val ex = intercept[IllegalArgumentException](sql(s"""
          | source = $t7| head 2
          | """.stripMargin))
     assert(ex.getMessage().contains("Invalid table name"))
   }
 
   test("test describe backtick table names and name contains '.'") {
     Seq(t1, t2, t3, t4).foreach { table =>
-      val frame = sql(
-        s"""
+      val frame = sql(s"""
            | describe $table
            | """.stripMargin)
       assert(frame.collect().length > 0)
@@ -165,15 +161,13 @@ class FlintSparkPPLBasicITSuite
     val t5 = "`spark_catalog`.default.`flint/ppl/test5.log`"
     val t6 = "spark_catalog.default.`flint_ppl_test6.log`"
     Seq(t5, t6).foreach { table =>
-      val ex = intercept[AnalysisException](sql(
-        s"""
+      val ex = intercept[AnalysisException](sql(s"""
            | describe $table
            | """.stripMargin))
       assert(ex.getMessage().contains("TABLE_OR_VIEW_NOT_FOUND"))
     }
     val t7 = "spark_catalog.default.flint_ppl_test7.log"
-    val ex = intercept[IllegalArgumentException](sql(
-      s"""
+    val ex = intercept[IllegalArgumentException](sql(s"""
          | describe $t7
          | """.stripMargin))
     assert(ex.getMessage().contains("Invalid table name"))

diff --git a/.../scala/org/opensearch/flint/spark/ppl/PPLLogicalPlanBasicQueriesTranslatorTestSuite.scala b/.../scala/org/opensearch/flint/spark/ppl/PPLLogicalPlanBasicQueriesTranslatorTestSuite.scala
@@ -36,7 +36,7 @@ class PPLLogicalPlanBasicQueriesTranslatorTestSuite
     assert(
       thrown.getMessage === "Invalid table name: t.b.c.d Syntax: [ database_name. ] table_name")
   }
-  
+
   test("test describe with backticks") {
     val context = new CatalystPlanContext
     val logPlan =
@@ -49,7 +49,7 @@ class PPLLogicalPlanBasicQueriesTranslatorTestSuite
       output = DescribeRelation.getOutputAttrs)
     comparePlans(expectedPlan, logPlan, false)
   }
-  
+
   test("test describe FQN table clause") {
     val context = new CatalystPlanContext
     val logPlan =