Spark - pt3

Signed-off-by: Andy HF Kwok <[email protected]>

Author: andy-hf-kwok

spark/src/test/scala/org/apache/spark/sql/CometTestBase.scala

@@ -21,6 +21,7 @@ package org.apache.spark.sql
 
 import java.util.concurrent.atomic.AtomicInteger
 
+import scala.annotation.nowarn
 import scala.concurrent.duration._
 import scala.reflect.ClassTag
 import scala.reflect.runtime.universe.TypeTag
@@ -550,6 +551,7 @@ abstract class CometTestBase
     case None => f(spark.read.format("parquet").load(path))
   }
 
+  @nowarn("cat=deprecation")
   protected def createParquetWriter(
       schema: MessageType,
       path: Path,
@@ -559,7 +561,6 @@ abstract class CometTestBase
       pageRowCountLimit: Int = ParquetProperties.DEFAULT_PAGE_ROW_COUNT_LIMIT,
       rowGroupSize: Long = 1024 * 1024L): ParquetWriter[Group] = {
     val hadoopConf = spark.sessionState.newHadoopConf()
-
     ExampleParquetWriter
       .builder(path)
       .withDictionaryEncoding(dictionaryEnabled)