Spark Streaming 'numRecords must not be negative'问题解决

转载自：http://blog.csdn.net/xueba207/article/details/51135423 问题描述 笔者使用spark streaming读取Kakfa中的数据，做进一步处理，用到了KafkaUtil的createDirectStream()方法；该方法不会自动保存top
posted @ 2018-01-30 11:33  四叶草Grass  阅读(1087)  评论(0)  编辑  收藏  举报