Fixing testcase failure due to Spark version upgrade (#114)

aapidinomm · web-flow · commit 04ea34b3309a · 2023-04-13T09:52:29.000-07:00
* Support Spark 3.3 and EMR 6.10

* Fixing test_scala_spark_multinode testcase failure with Spark-3.3
diff --git a/test/resources/code/scala/hello-scala-spark/src/main/scala/com/amazonaws/sagemaker/spark/test/HelloScalaSparkApp.scala b/test/resources/code/scala/hello-scala-spark/src/main/scala/com/amazonaws/sagemaker/spark/test/HelloScalaSparkApp.scala
@@ -37,7 +37,7 @@ object HelloScalaSparkApp {
     println("Got a Spark session with version: " + spark.version)
 
     spark.sparkContext.parallelize(Seq("Hello", "Hola", "Bonjour")).foreach { case greeting: String =>
-      System.err.println(s"I'm an executor, $greeting!")
+      println("I'm an executor, " + greeting)
     }
 
     // Load test data set

Original file line number	Diff line number	Diff line change
`@@ -37,7 +37,7 @@ object HelloScalaSparkApp {`
`37`	`37`	`println("Got a Spark session with version: " + spark.version)`
`38`	`38`
`39`	`39`	`spark.sparkContext.parallelize(Seq("Hello", "Hola", "Bonjour")).foreach { case greeting: String =>`
`40`		`- System.err.println(s"I'm an executor, $greeting!")`
	`40`	`+ println("I'm an executor, " + greeting)`
`41`	`41`	`}`
`42`	`42`
`43`	`43`	`// Load test data set`