openstack
/
sahara-tests
Code Issues Proposed changes
sahara-tests/sahara_tests/scenario/defaults/edp-examples/edp-spark
History
Jeremy Freudberg 1eb866f646 Fix URL of Maven Central Repository 
Change-Id: I180216b76d8010462312c1101ddd9761971dec11
Story: 2007996
Task: 40635
 		2020-08-10 09:52:10 -04:00
..
wordcountapp add impl of SparkWordCount example 2016-09-19 18:36:14 +00:00
NOTICE.txt Move default templates to framework repo 2016-04-07 17:37:27 +03:00
README.rst Fix URL of Maven Central Repository 2020-08-10 09:52:10 -04:00
sample_input.txt Move default templates to framework repo 2016-04-07 17:37:27 +03:00
spark-kafka-example.py Move default templates to framework repo 2016-04-07 17:37:27 +03:00
spark-pi.py embedded jars: replace spark-example.jar 2016-08-05 23:56:53 +03:00
spark-wordcount.jar add impl of SparkWordCount example 2016-09-19 18:36:14 +00:00

README.rst

Example Spark Job

This example contains the compiled classes for SparkPi extracted from the example jar distributed with Apache Spark version 1.3.1.

SparkPi example estimates Pi. It can take a single optional integer argument specifying the number of slices (tasks) to use.

Example spark-wordcount Job

spark-wordcount is a modified version of the WordCount example from Apache Spark. It can read input data from hdfs or swift container, then output the number of occurrences of each word to standard output or hdfs.

Launching wordcount job from Sahara UI

  1. Create a job binary that points to spark-wordcount.jar.

  2. Create a job template and set spark-wordcount.jar as the main binary of the job template.

  3. Create a Swift container with your input file. As example, you can upload sample_input.txt.

  4. Launch job:

    1. Put path to input file in args
    2. Put path to output file in args
    3. Fill the Main class input with the following class: sahara.edp.spark.SparkWordCount
    4. Put the following values in the job's configs: edp.spark.adapt_for_swift with value True, fs.swift.service.sahara.password with password for your username, and fs.swift.service.sahara.username with your username. These values are required for correct access to your input file, located in Swift.
    5. Execute the job. You will be able to view your output in hdfs.

Launching spark-kafka-example

  1. Create a cluster with Kafka Broker, ZooKeeper and Spark History Server. The Ambari plugin can be used for that purpose. Please, use your keypair during cluster creation to have the ability to ssh in instances with that processes. For simplicity, these services should located on same the node.
  2. Ssh to the node with the Kafka Broker service. Create a sample topic using the following command: path/kafka-topics.sh --create --zookeeper localhost:2181 \ --replication-factor 1 --partitions 1 --topic test-topic. Also execute path/kafka-console-producer.sh --broker-list \ localhost:6667 --topic test-topic and then put several messages in the topic. Please, note that you need to replace the values localhost and path with your own values.
  3. Download the Spark Streaming utils to the node with your Spark History Server from this URL: https://repo1.maven.org/maven2/org/apache/spark/spark-streaming-kafka-assembly_2.10/1.4.1/spark-streaming-kafka-assembly_2.10-1.4.1.jar. Now you are ready to launch your job from sahara UI.
  4. Create a job binary that points to spark-kafka-example.py. Also you need to create a job that uses this job binary as a main binary.
  5. Execute the job with the following job configs: edp.spark.driver.classpath with a value that points to the utils downloaded during step 2. Also the job should be run with the following arguments: localhost:2181 as the first argument, test-topic as the second, and 30 as the third.
  6. Congratulations, your job was successfully launched!