1、streamingcontext 读取kafka数据2、使用dstram map函数中，拼接查询语句，使用 sparkcontext 通过查询语句进行读取es数据库问题：会报错提示 task 没有序列化 sparkcontex未序列化 这个应该怎么解决啊
如果在dstream的转换函数中 无法使用sparkcontext ,name怎么通过查询语句查询ES库呢？