diff --git a/integ-test/src/integration/scala/org/opensearch/flint/spark/ppl/FlintSparkPPLTrendlineITSuite.scala b/integ-test/src/integration/scala/org/opensearch/flint/spark/ppl/FlintSparkPPLTrendlineITSuite.scala index a9cd93765..fb22bc7c4 100644 --- a/integ-test/src/integration/scala/org/opensearch/flint/spark/ppl/FlintSparkPPLTrendlineITSuite.scala +++ b/integ-test/src/integration/scala/org/opensearch/flint/spark/ppl/FlintSparkPPLTrendlineITSuite.scala @@ -308,10 +308,10 @@ class FlintSparkPPLTrendlineITSuite val results: Array[Row] = frame.collect() val expectedResults: Array[Row] = Array( - Row("Jake", 70, "California", "USA", 2023, 4, null), - Row("Hello", 30, "New York", "USA", 2023, 4, null), - Row("John", 25, "Ontario", "Canada", 2023, 4, 34.166666666666664), - Row("Jane", 20, "Quebec", "Canada", 2023, 4, 23.333333333333332)) + Row("Jane", 20, "Quebec", "Canada", 2023, 4, null), + Row("John", 25, "Ontario", "Canada", 2023, 4, null), + Row("Hello", 30, "New York", "USA", 2023, 4, 26.666666666666668), + Row("Jake", 70, "California", "USA", 2023, 4, 49.166666666666664)) // Compare the results implicit val rowOrdering: Ordering[Row] = Ordering.by[Row, String](_.getAs[String](0)) @@ -449,10 +449,6 @@ class FlintSparkPPLTrendlineITSuite Seq(UnresolvedAttribute("name"),UnresolvedAttribute("doubled_age"),UnresolvedAttribute("doubled_age_wma")), Project(trendlineProjectList, sortedTable )) - // scalastyle:off - println(expectedPlan.toString()) - println(logicalPlan.toString()) - // scalastyle:on println /** *