Change in Spark caused the 3.1.0 CI to fail (NVIDIA#988)

* fix CI * empty commit Signed-off-by: Raza Jafri <rjafri@nvidia.com> Co-authored-by: Raza Jafri <rjafri@nvidia.com>
nartal1 · Oct 20, 2020 · 19016e3 · 19016e3
1 parent 44b30be
commit 19016e3
Showing 1 changed file with 9 additions and 2 deletions.
diff --git a/...scala/org/apache/spark/sql/execution/datasources/parquet/rapids/ParquetMaterializer.scala b/...scala/org/apache/spark/sql/execution/datasources/parquet/rapids/ParquetMaterializer.scala
@@ -29,14 +29,21 @@ import org.apache.spark.sql.types.StructType
 /**
  * This class exposes the ParquetRecordMaterializer
  */
-class ParquetRecordMaterializer(parquetSchema: MessageType,
+class ParquetRecordMaterializer(
+   parquetSchema: MessageType,
    catalystSchema: StructType,
    schemaConverter: ParquetToSparkSchemaConverter,
    convertTz: Option[ZoneId],
    datetimeRebaseMode: LegacyBehaviorPolicy.Value) extends RecordMaterializer[InternalRow] {
 
   private val rootConverter = new ParquetRowConverter(
-    schemaConverter, parquetSchema, catalystSchema, convertTz, datetimeRebaseMode, NoopUpdater)
+    schemaConverter,
+    parquetSchema,
+    catalystSchema,
+    convertTz,
+    datetimeRebaseMode,
+    LegacyBehaviorPolicy.EXCEPTION,
+    NoopUpdater)
 
   override def getCurrentRecord: InternalRow = rootConverter.currentRecord