Skip to content

Commit

Permalink
feat: Support Spark 3.5.1 (#373)
Browse files Browse the repository at this point in the history
* feat: Support Spark 3.5.1

* changelog

* changelog

* changelog
  • Loading branch information
sbernauer committed Mar 12, 2024
1 parent bffc78d commit e7870b7
Show file tree
Hide file tree
Showing 26 changed files with 26 additions and 22 deletions.
2 changes: 2 additions & 0 deletions CHANGELOG.md
Expand Up @@ -7,6 +7,7 @@ All notable changes to this project will be documented in this file.
### Added

- Helm: support labels in values.yaml ([#344]).
- Support version `3.5.1` ([#373]).
- Support version `3.4.2` ([#357]).
- `spec.job.config.volumeMounts` property to easily mount volumes on the job pod ([#359])

Expand All @@ -31,6 +32,7 @@ All notable changes to this project will be documented in this file.
[#355]: https://github.com/stackabletech/spark-k8s-operator/pull/355
[#357]: https://github.com/stackabletech/spark-k8s-operator/pull/357
[#359]: https://github.com/stackabletech/spark-k8s-operator/pull/359
[#373]: https://github.com/stackabletech/spark-k8s-operator/pull/373

## [23.11.0] - 2023-11-24

Expand Down
2 changes: 1 addition & 1 deletion docs/modules/spark-k8s/examples/example-encapsulated.yaml
Expand Up @@ -5,7 +5,7 @@ metadata:
name: spark-pi
spec:
sparkImage:
productVersion: 3.5.0 # <1>
productVersion: 3.5.1 # <1>
mode: cluster
mainClass: org.apache.spark.examples.SparkPi
mainApplicationFile: /stackable/spark/examples/jars/spark-examples.jar # <2>
Expand Down
2 changes: 1 addition & 1 deletion docs/modules/spark-k8s/examples/example-history-app.yaml
Expand Up @@ -5,7 +5,7 @@ metadata:
name: spark-pi-s3-1
spec:
sparkImage:
productVersion: 3.5.0
productVersion: 3.5.1
pullPolicy: IfNotPresent
mode: cluster
mainClass: org.apache.spark.examples.SparkPi
Expand Down
Expand Up @@ -5,7 +5,7 @@ metadata:
name: spark-history
spec:
image:
productVersion: 3.5.0
productVersion: 3.5.1
logFileDirectory: # <1>
s3:
prefix: eventlogs/ # <2>
Expand Down
Expand Up @@ -6,7 +6,7 @@ metadata:
namespace: default
spec:
sparkImage:
productVersion: 3.5.0
productVersion: 3.5.1
mode: cluster
mainApplicationFile: s3a://stackable-spark-k8s-jars/jobs/ny-tlc-report-1.1.0.jar # <3>
mainClass: tech.stackable.demo.spark.NYTLCReport
Expand Down
Expand Up @@ -6,7 +6,7 @@ metadata:
namespace: default
spec:
sparkImage:
productVersion: 3.5.0
productVersion: 3.5.1
mode: cluster
mainApplicationFile: s3a://stackable-spark-k8s-jars/jobs/ny_tlc_report.py # <1>
args:
Expand Down
Expand Up @@ -7,7 +7,7 @@ metadata:
spec:
image: docker.stackable.tech/stackable/ny-tlc-report:0.1.0 # <1>
sparkImage:
productVersion: 3.5.0
productVersion: 3.5.1
mode: cluster
mainApplicationFile: local:///stackable/spark/jobs/ny_tlc_report.py # <2>
args:
Expand Down
2 changes: 1 addition & 1 deletion docs/modules/spark-k8s/examples/example-sparkapp-pvc.yaml
Expand Up @@ -6,7 +6,7 @@ metadata:
namespace: default
spec:
sparkImage:
productVersion: 3.5.0
productVersion: 3.5.1
mode: cluster
mainApplicationFile: s3a://stackable-spark-k8s-jars/jobs/ny-tlc-report-1.0-SNAPSHOT.jar # <1>
mainClass: org.example.App # <2>
Expand Down
Expand Up @@ -5,7 +5,7 @@ metadata:
name: example-sparkapp-s3-private
spec:
sparkImage:
productVersion: 3.5.0
productVersion: 3.5.1
mode: cluster
mainApplicationFile: s3a://my-bucket/spark-examples.jar # <1>
mainClass: org.apache.spark.examples.SparkPi # <2>
Expand Down
Expand Up @@ -6,7 +6,7 @@ metadata:
namespace: default
spec:
sparkImage:
productVersion: 3.5.0
productVersion: 3.5.1
mode: cluster
mainApplicationFile: local:///stackable/spark/examples/src/main/python/streaming/hdfs_wordcount.py
args:
Expand Down
Expand Up @@ -60,7 +60,7 @@ metadata:
namespace: default
spec:
sparkImage:
productVersion: 3.5.0
productVersion: 3.5.1
mode: cluster
mainApplicationFile: local:///stackable/spark/examples/src/main/python/pi.py
driver:
Expand Down
Expand Up @@ -60,7 +60,7 @@ metadata:
namespace: default
spec:
sparkImage:
productVersion: 3.5.0
productVersion: 3.5.1
mode: cluster
mainApplicationFile: local:///stackable/spark/examples/src/main/python/pi.py
driver:
Expand Down
3 changes: 2 additions & 1 deletion docs/modules/spark-k8s/partials/supported-versions.adoc
Expand Up @@ -3,6 +3,7 @@
// Stackable Platform documentation.
// Please sort the versions in descending order (newest first)

- 3.5.0 (Hadoop 3.3.4, Scala 2.12, Python 3.11, Java 11)
- 3.5.1 (Hadoop 3.3.4, Scala 2.12, Python 3.11, Java 11)
- 3.5.0 (Hadoop 3.3.4, Scala 2.12, Python 3.11, Java 11) (deprecated)
- 3.4.2 (Hadoop 3.3.4, Scala 2.12, Python 3.11, Java 11) (LTS)
- 3.4.1 (Hadoop 3.3.4, Scala 2.12, Python 3.11, Java 11) (deprecated)
4 changes: 2 additions & 2 deletions examples/README-examples.md
Expand Up @@ -50,10 +50,10 @@ Several resources are needed in this store. These can be loaded like this:

````text
kubectl exec minio-mc-0 -- sh -c 'mc alias set test-minio http://test-minio:9000/'
kubectl cp examples/ny-tlc-report-1.1.0-3.5.0.jar minio-mc-0:/tmp
kubectl cp examples/ny-tlc-report-1.1.0-3.5.1.jar minio-mc-0:/tmp
kubectl cp apps/ny_tlc_report.py minio-mc-0:/tmp
kubectl cp examples/yellow_tripdata_2021-07.csv minio-mc-0:/tmp
kubectl exec minio-mc-0 -- mc cp /tmp/ny-tlc-report-1.1.0-3.5.0.jar test-minio/my-bucket
kubectl exec minio-mc-0 -- mc cp /tmp/ny-tlc-report-1.1.0-3.5.1.jar test-minio/my-bucket
kubectl exec minio-mc-0 -- mc cp /tmp/ny_tlc_report.py test-minio/my-bucket
kubectl exec minio-mc-0 -- mc cp /tmp/yellow_tripdata_2021-07.csv test-minio/my-bucket
````
Expand Down
Binary file not shown.
2 changes: 1 addition & 1 deletion examples/ny-tlc-report-external-dependencies.yaml
Expand Up @@ -6,7 +6,7 @@ metadata:
namespace: default
spec:
sparkImage:
productVersion: 3.5.0
productVersion: 3.5.1
pullPolicy: IfNotPresent
mode: cluster
mainApplicationFile: s3a://my-bucket/ny_tlc_report.py
Expand Down
2 changes: 1 addition & 1 deletion examples/ny-tlc-report-image.yaml
Expand Up @@ -7,7 +7,7 @@ metadata:
spec:
# everything under /jobs will be copied to /stackable/spark/jobs
image: docker.stackable.tech/stackable/ny-tlc-report:0.1.0
sparkImage: docker.stackable.tech/stackable/spark-k8s:3.5.0-stackable0.0.0-dev
sparkImage: docker.stackable.tech/stackable/spark-k8s:3.5.1-stackable0.0.0-dev
sparkImagePullPolicy: IfNotPresent
mode: cluster
mainApplicationFile: local:///stackable/spark/jobs/ny_tlc_report.py
Expand Down
4 changes: 2 additions & 2 deletions examples/ny-tlc-report.yaml
Expand Up @@ -13,9 +13,9 @@ metadata:
name: spark-ny-cm
spec:
sparkImage:
productVersion: 3.5.0
productVersion: 3.5.1
mode: cluster
mainApplicationFile: s3a://my-bucket/ny-tlc-report-1.1.0-3.5.0.jar
mainApplicationFile: s3a://my-bucket/ny-tlc-report-1.1.0-3.5.1.jar
mainClass: tech.stackable.demo.spark.NYTLCReport
volumes:
- name: cm-job-arguments
Expand Down
2 changes: 1 addition & 1 deletion rust/crd/src/affinity.rs
Expand Up @@ -47,7 +47,7 @@ mod test {
name: spark-history
spec:
image:
productVersion: 3.5.0
productVersion: 3.5.1
logFileDirectory:
s3:
prefix: eventlogs/
Expand Down
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
7 changes: 4 additions & 3 deletions tests/test-definition.yaml
Expand Up @@ -8,13 +8,14 @@ dimensions:
- 3.4.1
- 3.4.2
- 3.5.0
- 3.5.1
# Alternatively, if you want to use a custom image, append a comma and the full image name to the product version
# as in the example below.
# - 3.5.0,docker.stackable.tech/sandbox/spark-k8s:3.5.0-stackable0.0.0-dev
# - 3.5.1,docker.stackable.tech/sandbox/spark-k8s:3.5.1-stackable0.0.0-dev
- name: spark-delta-lake
values:
- 3.5.0
# - 3.5.0,docker.stackable.tech/sandbox/spark-k8s:3.5.0-stackable0.0.0-dev
- 3.5.1
# - 3.5.1,docker.stackable.tech/sandbox/spark-k8s:3.5.1-stackable0.0.0-dev
- name: ny-tlc-report
values:
- 0.1.0
Expand Down

0 comments on commit e7870b7

Please sign in to comment.