File tree Expand file tree Collapse file tree 3 files changed +0
-17
lines changed
lesson_05_monitoring_and_optimizations
lesson_06__deploy_to_cloud/video_01__infra_aws/scripts Expand file tree Collapse file tree 3 files changed +0
-17
lines changed Original file line number Diff line number Diff line change @@ -4,10 +4,6 @@ import org.apache.spark.sql.functions.broadcast
4
4
5
5
object JoinOptimizationApp extends SparkApp {
6
6
7
- // ./bin/spark-shell --master spark://spark-master:7077 --driver-memory 3g --conf spark.sql.adaptive.enabled=false
8
-
9
- spark.sparkContext.setLogLevel(" WARN" )
10
-
11
7
import spark .implicits ._
12
8
13
9
spark.sparkContext.setJobGroup(" join without optimization" , " join without optimization" )
@@ -39,6 +35,4 @@ object JoinOptimizationApp extends SparkApp {
39
35
veryLargeDF.join(broadcast(largeDF), " id" ).count()
40
36
41
37
spark.sparkContext.clearJobGroup()
42
-
43
- Thread .sleep(1000000 )
44
38
}
Original file line number Diff line number Diff line change @@ -4,10 +4,6 @@ import org.apache.spark.sql.functions.when
4
4
5
5
object SkewJoinApp extends SparkApp {
6
6
7
- // ./bin/spark-shell --master spark://spark-master:7077 --driver-memory 3g --executor-memory 1024mb --conf spark.sql.autoBroadcastJoinThreshold=-1 --conf spark.sql.adaptive.enabled=false
8
-
9
- spark.sparkContext.setLogLevel(" WARN" )
10
-
11
7
import spark .implicits ._
12
8
13
9
spark.sparkContext.setJobGroup(" skewed data" , " skewed data" )
@@ -40,6 +36,4 @@ object SkewJoinApp extends SparkApp {
40
36
joinedAQE.count()
41
37
42
38
spark.sparkContext.clearJobGroup()
43
-
44
- Thread .sleep(1000000 )
45
39
}
Original file line number Diff line number Diff line change @@ -63,9 +63,4 @@ aws iam create-service-linked-role --aws-service-name elasticmapreduce.amazonaws
63
63
echo " Creating Step Functions state machine for EMR cluster"
64
64
aws stepfunctions create-state-machine --name " EMR_StepFunctions_Machine" --definition file://policies/state_machine_definition.json --role-arn arn:aws:iam::$AWS_ACCOUNT_ID :role/$EMR_STEP_FUNCTIONS_ROLE --profile $AWS_PROFILE
65
65
66
- # Start execution of Step Functions (Uncomment to enable execution)
67
- # echo "Starting execution of Step Functions state machine"
68
-
69
- aws stepfunctions start-execution --state-machine-arn arn:aws:states:eu-west-1:010928190667:stateMachine:EMR_StepFunctions_Machine --profile emr-user
70
-
71
66
echo " Setup complete."
You can’t perform that action at this time.
0 commit comments