Github user vanzin commented on a diff in the pull request:

    https://github.com/apache/spark/pull/19448#discussion_r143878105
  
    --- Diff: 
sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/parquet/ParquetFileFormat.scala
 ---
    @@ -138,6 +138,13 @@ class ParquetFileFormat
           conf.setBoolean(ParquetOutputFormat.ENABLE_JOB_SUMMARY, false)
         }
     
    +    if (conf.getBoolean(ParquetOutputFormat.ENABLE_JOB_SUMMARY, false)
    +      && 
!classOf[ParquetOutputCommitter].isAssignableFrom(committerClass)) {
    +      // output summary is requested, but the class is not a Parquet 
Committer
    +      throw new RuntimeException(s"Committer $committerClass is not a 
ParquetOutputCommitter" +
    --- End diff --
    
    `IllegalArgumentException` or some other better exception?


---

---------------------------------------------------------------------
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail: reviews-h...@spark.apache.org

Reply via email to