File tree Expand file tree Collapse file tree 3 files changed +10
-9
lines changed Expand file tree Collapse file tree 3 files changed +10
-9
lines changed Original file line number Diff line number Diff line change @@ -484,11 +484,8 @@ impl SparkApplication {
484
484
format!( "--conf spark.kubernetes.authenticate.driver.serviceAccountName={}" , serviceaccount_name) ,
485
485
format!( "--conf spark.driver.defaultJavaOptions=-Dlog4j.configurationFile={VOLUME_MOUNT_PATH_LOG_CONFIG}/{LOG4J2_CONFIG_FILE}" ) ,
486
486
format!( "--conf spark.driver.extraClassPath=/stackable/spark/extra-jars/*" ) ,
487
- //"--conf spark.driver.userClassPathFirst=true".to_string(),
488
- "--conf spark.driver.userClassPathFirst=true" . to_string( ) ,
489
487
format!( "--conf spark.executor.defaultJavaOptions=-Dlog4j.configurationFile={VOLUME_MOUNT_PATH_LOG_CONFIG}/{LOG4J2_CONFIG_FILE}" ) ,
490
488
format!( "--conf spark.executor.extraClassPath=/stackable/spark/extra-jars/*" ) ,
491
- //"--conf spark.executor.userClassPathFirst=true".to_string(),
492
489
] ) ;
493
490
494
491
// See https://spark.apache.org/docs/latest/running-on-kubernetes.html#dependency-management
Original file line number Diff line number Diff line change @@ -37,6 +37,12 @@ def check_sent_events():
37
37
assert sentEvents is None or \
38
38
sentEvents ['sentEventsTotal' ] == 0 , \
39
39
'Invalid log events were sent.'
40
+ elif componentId .find ('LogConfigSubmitSpark' ) > 0 :
41
+ # [*LogConfigSubmitSpark] components do not log in XML format
42
+ # because spark-submit doesn't know about the /stackable/spark/extra-jars folder.
43
+ assert sentEvents is None or \
44
+ sentEvents ['sentEventsTotal' ] == 0 , \
45
+ f'Found events for { componentId } but did not expect any.'
40
46
else :
41
47
assert sentEvents is not None and \
42
48
sentEvents ['sentEventsTotal' ] > 0 , \
Original file line number Diff line number Diff line change @@ -5,17 +5,15 @@ dimensions:
5
5
- " false"
6
6
- name : spark
7
7
values :
8
- # - 3.4.1
8
+ - 3.4.1
9
9
- 3.5.0
10
10
# Alternatively, if you want to use a custom image, append a comma and the full image name to the product version
11
11
# as in the example below.
12
- # - 3.4.1,docker.stackable.tech/sandbox/spark-k8s:3.4.1-stackable0.0.0-dev
13
- # - 3.5.0,docker.stackable.tech/sandbox/spark-k8s:3.5.0-stackable0.0.0-dev
12
+ # - 3.5.0,docker.stackable.tech/sandbox/spark-k8s:3.5.0-stackable0.0.0-dev
14
13
- name : spark-delta
15
14
values :
16
- # - 3.5.0
17
- - 3.5.0,docker.stackable.tech/sandbox/spark-k8s:3.5.0-stackable0.0.0-dev
18
-
15
+ - 3.5.0
16
+ # - 3.5.0,docker.stackable.tech/sandbox/spark-k8s:3.5.0-stackable0.0.0-dev
19
17
- name : ny-tlc-report
20
18
values :
21
19
- 0.1.0
You can’t perform that action at this time.
0 commit comments