我们学习编程语言的时候，第一个程序就是打印一下 “hello world” ，对于大数据领域的第一个任务则是wordcount。那我们就开始我们的第一个spark任务吧！

下载spark

官方下载地址：Apache Download Mirrors 下载完毕以后，直接tar解压即可。

本地启动spark集群

环境只是为了让我们能够运行我们的程序，所以我们的任务是写任务而不是搭建环境。搭建环境的部分，可能运维比我们更专业。

安装官网我们启动一个standalon模式，Spark Standalone Mode - Spark 4.0.0 Documentation。

启动完以后master我们就可以在8080端口上看到我们的spark集群了。

接着启动一个worker，启动的时候需要master的地址。我们本地启动的，所以localhost就可以了。./sbin/start-worker.sh spark://bogon:7077 ,master的url可以从master 8080的界面看到，这个记得一定要写正确，要不启动worker的时候就有问题了。否则这个worker节点不现实worker个数的。

构建我们的jar程序

我们直接参考官网的代码（注意：这是学习的方式方法，看到别人博客直接写的入门代码。其实官方是第一手资料）Spark Streaming - Spark 4.0.0 Documentation

代码

def main(args: Array[String]): Unit = {println("======== start ==========")val conf = new SparkConf().setAppName("test")val ssc = new StreamingContext(conf, Seconds(1))val source = ssc.socketTextStream("localhost", 9999)val words = source.flatMap(_.split(","))val paris = words.map(word => (word, 1))val wordCounts = paris.reduceByKey(_ + _)wordCounts.print()ssc.start()ssc.awaitTermination()}

编译打包jar，然后提交submit

./bin/spark-submit \--class demo.WordCount \--executor-memory 512M  \--total-executor-cores 2 \--master spark://localhost:7077 \--deploy-mode client \--verbose \/path/spark-task-1.0-SNAPSHOT.jar

Submitting Applications - Spark 4.0.0 Documentation

查看日志打印

总结

小结一下，其实看似很简单的一个demo。过程也是遇到了很多的问题，1、是启动 worker的时候需要制定master的url地址，这个需要从8080端口查看。2、发现自己的代码无法提交到集群中，结果发现是代码里面setMaster了，所以去掉。3、打包的时候提示找不到class，因为是maven构建的java程序。自己添加的scala包，所以需要打包的时候指定一下scala路径，把下面的class打包进去。

多实践才能发现问题，有时候只是知道了理论，看似懂了，其实离懂了还是差了一些。