-
Notifications
You must be signed in to change notification settings - Fork 56
Description
hi, my scala version is 2.12.15 , spark version is 3.0, I use spark-tfrecord_2.12:0.40, but met an error:
Caused by: java.lang.NullPointerException
at org.apache.hadoop.conf.Configuration.(Configuration.java:821)
at org.apache.hadoop.mapred.JobConf.(JobConf.java:440)
at org.apache.hadoop.mapreduce.task.JobContextImpl.(JobContextImpl.java:67)
at org.apache.hadoop.mapreduce.task.TaskAttemptContextImpl.(TaskAttemptContextImpl.java:49)
at org.apache.hadoop.mapreduce.task.TaskAttemptContextImpl.(TaskAttemptContextImpl.java:44)
at com.linkedin.spark.datasources.tfrecord.TFRecordFileReader$.readFile(TFRecordFileReader.scala:32)
at com.linkedin.spark.datasources.tfrecord.DefaultSource.$anonfun$buildReader$1(DefaultSource.scala:132)
I tested the following case, but it runs well:
- sc.textFile("xxxx")
- spark.read.textFile("xxx")
Do you have any ideas about this error? I am really confused. lol.