你的浏览器禁用了JavaScript, 请开启后刷新浏览器获得更好的体验!
输入关键字进行搜索
搜索:
发现
问题
笔记
话题
登录
Spark
将日志数据从flume导入到kafka时,同时用sparkstreaming读取数据时报错
将日志数据从flume导入到kafka时,同时用sparkstreaming读取数据时报如下错误
这个怎么破?
与内容相关的链接
提交
2 个回复
奔跑的大象
赞同来自:
为什么不flume导入kafka,spark streaming消费kafka数据呢?
ycyzlp
赞同来自:
我在ide中写了spark streaming和kafka集成的代码,执行这个程序后,同时启动了一个生产者终端,在终端中输入简单的几个字母后,ide可以将生产都输入的字母打印出来,我用flume导入kafka其实就是想模拟一下这个生产者,因为我发现如果等flume导入kafka后,再执行这个spark streaming集成kafka的代码,ide是读不出来数据的,是我的代码有问题还是我的思路不对?还请老师指点
要回复问题请先
登录
或
注册
发起人
ycyzlp
相关问题
第二课《2 分布式数据收集:Flume 原理与应用》
大数据的走向会无休止吗?spark之后有flink,在之后呢?
部署hadoop HA + zookeeper时 ,格式化zookeeper报错
DCon2015 中国大数据技术嘉年华——资料导航帖
bootcamps安装完后执行测试程序,报错,这个怎么解决呢?防火墙啥的都已经关了呀!
邹博老师在决策树一节回答的问题,在有偏的情况下要“重采样”。为什么在不同类别数据不平均时,要重采样或降采样呢?直接用不行吗?直接用在影响决策树的哪个地方?谢谢!
hbase 大数据存储 内存溢出。
启动Hadoop集群: Step1 : 在各个JournalNode节点上,输入以下命令启动journalnode服务: sbin/hadoop-daemon.sh start journalnode Step2: 在[nn1]上,对其进行格式化,并启动: bin/hdfs namenode -format sbin/hadoop-daemon.sh start namenode Step3: 在[nn2]上,同步nn1的元数据信息: bin/hdfs namenode -bootstrapStand
远程登录主机之后用eclipse创建maven项目时报错
第二周作业,读取文件出问题
Hive中千亿行数据的group by操作无法作业的问题
问题状态
最新活动:
2015-11-26 19:44
浏览:
3080
关注:
3
人
2 个回复
奔跑的大象
赞同来自:
ycyzlp
赞同来自: