压缩的数据是不是有损坏啊,程序报空指针异常?运行测试数据没有问题。
代码就是简单的读取数据,然后输出,中间没有任何处理过程。
System.setProperty(“icode”, “BE6DD1FA1FC03060”)
val input = s"hdfs://hadoop1:9000/access/20190130/*"
var logDf = spark.read.format(“com.imooc.bigdata.spark.pk”).option(“path”, input).load()
val l = logDf.count()
println(l)