运行spark0901后,没有出现隔五秒的批次输出,是哪里设置错了嘛?

来源:9-6 -核心概念之StreamingContext

慕勒1019045

2018-09-29

运行后输出以下,可能提问很小白,老师帮忙看看,谢谢~图片描述
/home/hadoop/app/python3/bin/python3.6 /home/hadoop/PycharmProjects/pyspark_project/class_09/spark0901.py localhost 9996
18/09/28 21:43:42 WARN NativeCodeLoader: Unable to load native-hadoop library for your platform… using builtin-java classes where applicable
Using Spark’s default log4j profile: org/apache/spark/log4j-defaults.properties
Setting default log level to “WARN”.
To adjust logging level use sc.setLogLevel(newLevel). For SparkR, use setLogLevel(newLevel).
[Stage 0:> (0 + 1) / 1][Stage 2:> (0 + 0) / 1]

[hadoop@hadoop000 spark-2.3.0-bin-2.6.0-cdh5.7.0]$ nc -lk 9996

写回答

4回答

Michael_PK

2018-09-29

你有输入数据吗?没输入数据就没有输出,但是五秒还是跑的,只不过空的

0
1
慕勒1019045
非常感谢!谢谢老师
2018-09-29
共1条回复

慕勒1019045

提问者

2018-09-29

nc输入数据后,我的控制台是这样的//img.mukewang.com/szimg/5baee6be00011c6c08680322.jpg

0
0

慕勒1019045

提问者

2018-09-29

nc输入数据前后都没有老师pycharm里面显示的那种批次显示的内容

//img.mukewang.com/szimg/5baee4970001c15706660310.jpg

//img.mukewang.com/szimg/5baee4970001b67c05840193.jpg

//img.mukewang.com/szimg/5baee497000157b506120126.jpg


0
1
Michael_PK
你master写的是什么
2018-09-29
共1条回复

慕勒1019045

提问者

2018-09-29

网页端好像有显示5秒批次//img.mukewang.com/szimg/5baede060001ec2f13140334.jpg

0
0

Python3实战Spark大数据分析及调度

使用Python3对Spark应用程序进行开发调优,掌握Azkaban任务调度

1046 学习 · 434 问题

查看课程