-
Notifications
You must be signed in to change notification settings - Fork 2
/
06-deploy-custom-log-config-spark-app.yaml.j2
79 lines (75 loc) · 2.07 KB
/
06-deploy-custom-log-config-spark-app.yaml.j2
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
---
apiVersion: v1
kind: ConfigMap
metadata:
name: spark-log-config
data:
log4j2.properties: |-
appenders = FILE
appender.FILE.type = File
appender.FILE.name = FILE
appender.FILE.fileName = /stackable/log/spark/spark.log4j2.xml
appender.FILE.layout.type = XMLLayout
rootLogger.level = INFO
rootLogger.appenderRefs = FILE
rootLogger.appenderRef.FILE.ref = FILE
---
apiVersion: v1
kind: ConfigMap
metadata:
name: spark-submit-log-config
data:
log4j2.properties: |-
appenders = FILE
appender.FILE.type = File
appender.FILE.name = FILE
appender.FILE.fileName = /stackable/log/spark-submit/spark.log4j2.xml
appender.FILE.layout.type = XMLLayout
rootLogger.level = INFO
rootLogger.appenderRefs = FILE
rootLogger.appenderRef.FILE.ref = FILE
---
apiVersion: spark.stackable.tech/v1alpha1
kind: SparkApplication
metadata:
name: spark-custom-log-config
spec:
version: "1.0"
sparkImage:
{% if test_scenario['values']['spark'].find(",") > 0 %}
custom: "{{ test_scenario['values']['spark'].split(',')[1] }}"
productVersion: "{{ test_scenario['values']['spark'].split(',')[0] }}"
{% else %}
productVersion: "{{ test_scenario['values']['spark'] }}"
{% endif %}
pullPolicy: IfNotPresent
image: docker.stackable.tech/stackable/ny-tlc-report:{{ test_scenario['values']['ny-tlc-report'] }}
vectorAggregatorConfigMapName: spark-vector-aggregator-discovery
mode: cluster
mainClass: org.apache.spark.examples.SparkALS
mainApplicationFile: local:///stackable/spark/examples/jars/spark-examples.jar
job:
config:
logging:
enableVectorAgent: true
containers:
spark-submit:
custom:
configMap: spark-submit-log-config
driver:
config:
logging:
enableVectorAgent: true
containers:
spark:
custom:
configMap: spark-log-config
executor:
replicas: 1
config:
logging:
enableVectorAgent: true
containers:
spark:
custom:
configMap: spark-log-config