File tree Expand file tree Collapse file tree
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -358,6 +358,9 @@ object HoodieFileIndex extends Logging {
358358 }
359359
360360 private def getQueryPath (options : Map [String , String ]) = {
361- new Path (options.getOrElse(" path" , " 'path' option required" ))
361+ new Path (options.get(" path" ) match {
362+ case Some (p) => p
363+ case None => throw new IllegalArgumentException (" 'path' option required" )
364+ })
362365 }
363366}
Original file line number Diff line number Diff line change @@ -298,7 +298,7 @@ object SparkHoodieTableFileIndex {
298298 }
299299
300300 private def deduceQueryType (configProperties : TypedProperties ): HoodieTableQueryType = {
301- configProperties.asScala(QUERY_TYPE .key() ) match {
301+ configProperties.asScala(QUERY_TYPE .key) match {
302302 case QUERY_TYPE_SNAPSHOT_OPT_VAL => HoodieTableQueryType .SNAPSHOT
303303 case QUERY_TYPE_INCREMENTAL_OPT_VAL => HoodieTableQueryType .INCREMENTAL
304304 case QUERY_TYPE_READ_OPTIMIZED_OPT_VAL => HoodieTableQueryType .READ_OPTIMIZED
You can’t perform that action at this time.
0 commit comments