全部版块 我的主页
论坛 提问 悬赏 求职 新闻 读书 功能一区 经管百科 爱问频道
2627 1
2017-01-03
> df <- read.df(sqlContext,"hdfs://192.168.1.129:8077/tmp/vipcs.txt")
Error in invokeJava(isStatic = TRUE, className, methodName, ...) :
  java.lang.AssertionError: assertion failed: No predefined schema found, and no Parquet data files or summary files found under hdfs://192.168.1.129:8082/tmp/vipcs.txt.
        at scala.Predef$.assert(Predef.scala:179)
        at org.apache.spark.sql.execution.datasources.parquet.ParquetRelation$MetadataCache.org$apache$spark$sql$execution$datasources$parquet$ParquetRelation$MetadataCache$$readSchema(ParquetRelation.scala:512)
        at org.apache.spark.sql.execution.datasources.parquet.ParquetRelation$MetadataCache$$anonfun$12.apply(ParquetRelation.scala:421)
        at org.apache.spark.sql.execution.datasources.parquet.ParquetRelation$MetadataCache$$anonfun$12.apply(ParquetRelation.scala:421)
        at scala.Option.orElse(Option.scala:257)
        at org.apache.spark.sql.execution.datasources.parquet.ParquetRelation$MetadataCache.refresh(ParquetRelation.scala:421)
        at org.apache.spark.sql.execution.datasources.parquet.ParquetRelation.org$apache$spark$sql$execution$datasources$parquet$ParquetRelation$$metada

这个怎么处理,什么原因!
附件列表
1483421128(1).jpg

原图尺寸 27.93 KB

1483421128(1).jpg

二维码

扫码加我 拉你入群

请注明:姓名-公司-职位

以便审核进群资格,未注明则拒绝

全部回复
2017-7-31 15:54:53
应该是不能直接读取txt格式文件,你试一下jeson和csv
二维码

扫码加我 拉你入群

请注明:姓名-公司-职位

以便审核进群资格,未注明则拒绝

相关推荐
栏目导航
热门文章
推荐文章

说点什么

分享

扫码加好友,拉您进群
各岗位、行业、专业交流群