当我们生产者生产json 文件的时候   消费时用JSON读文件时,如下:

val values = kafkardd.map(t=>JSON.parseObject(t._2))

如果发生以下错误:
 Job aborted due to stage failure: Task 1 in stage 0.0 failed 1 times, most recent failure: Lost task 1.0 in stage 0.0 (TID 1, localhost, executor driver): com.alibaba.fastjson.JSONException: syntax error
注意:一定是json文件格式错误 去掉所有的空格,保留原有的格式


最新文章

  1. Android-做个性化的进度条
  2. Entity Framework 实体框架的形成之旅--几种数据库操作的代码介绍(9)
  3. java中+的使用
  4. WCF 遇到 由于线程退出或应用程序请求,已放弃 I/O 操作 ListenerContextInputStream
  5. HTML中,按钮button与submit区别是什么?
  6. 字符串长度计算、截取、url参数获取、计算百分比、时间戳格式化
  7. 什么要缓存curl资源
  8. C语言中的系统时间结构体类型
  9. OData语法
  10. Python datetime模块的datetime类
  11. CTF 字符统计1
  12. - configuration.module has an unknown property 'loader' 问题解决
  13. Go - WaitGroup
  14. C/S和B/S应用程序的区别
  15. SpringMVC Maven项目 java.lang.ClassNotFoundException: org.springframework.web.servlet.DispatcherServle
  16. 做一个懒COCOS2D-X程序猿(一)停止手打所有cpp文件到android.mk
  17. [knowledge][lisp] lisp与AI
  18. vprintf 和 vsnpintf 的用法
  19. 关于java内存泄露的总结--引用的类型:强引用,弱引用,软引用
  20. idea建立web项目servlet映射的地址/jsp访问不到

热门文章

  1. html:<link> 标签中的 media 属性
  2. 从windows CMD 命令行(CMD promp)运行Docker
  3. April 6 2017 Week 14 Thursday
  4. [转载]Memcached缓存服务的简单安装
  5. MySQL锁小结
  6. 2017.9.26 request请求参数用法
  7. 正定矩阵(Positive-definite Matrix)
  8. Python 初始—(项目 目录结构)
  9. Python 初始—(装饰器)
  10. mybatis两级缓存原理剖析