Yinan Li
7a34c91f6c
Use a Kubernetes Job to run spark-submit for multi-version support
2020-04-18 11:03:26 -07:00
Yinan Li
1c4486cdda
Removed legacy init-container related fields ( #750 )
2019-12-20 10:08:05 -08:00
Jiaxin Shan
0bd7592035
Add volumes support for Spark scratch space spark.local.dir ( #707 )
2019-12-15 15:05:40 -08:00
Yinan Li
baafaafeea
Fixed the client version used in sparkctl ( #681 )
2019-11-03 18:50:21 -08:00
kevin hogeland
55a1eebc0c
Generate CRD specs, bump to v1beta2 ( #578 )
...
* Generate CRD specs, bump to v1beta2
* Add short/singular CRD names
* Merge upstream/master
* Tweak Cores validation
* Fix typo, merge upstream
* Update remaining docs for v1beta2
2019-09-13 10:37:21 -07:00
Chaoran Yu
6609df0a18
Refactored integration tests ( #445 )
...
* Refactored integration tests
* Addressed review comments
2019-03-18 18:47:15 -07:00
Sarjeet Singh
a6fc6fb207
Add InClusterconfig for sparkctl if no kubeconfig provided ( #420 )
...
* Add InClusterconfig for sparkctl if no kubeconfig provided
* Importing os
* Updated based on review comment
* Minor fix for reordering import package
2019-02-21 14:47:51 -08:00
Yinan Li
c41576b5ff
Updated the use the v1beta1 version of the APIs
2019-01-17 10:45:54 -08:00
Grzegorz Lyczba
73ecfa80ac
rename CompletionTime to TerminationTime
2018-12-17 23:36:48 +01:00
akhurana001
8c7fdbb306
Operator State Management + Ingress Creation ( #291 )
...
* SparkOperator: Prometheus Metrics Integration
* Prometheus Metric Update
* Spark Operator:Prometheus Metric Integration
* PositiveGauge rework
* remove unwanted dependencies
* Propogating ScheduledSpark App Labels
* Doc update
* Metric Description update
* fix app wait
* SparkOperator: Prometheus Metrics Integration
* Spark Operator metrics:PR Comments
* SparkOperator: Set completion time for Failed App
* Operator Metrics: PR comments
* Spark Operator: PR Comments
* Controller Update
* PR Comments
* Docs Update
* Driver State Transition Check Update
* Operator State Management
* Clean-up
* Exposing Spark Application Id in Operator
* SparkAppId updates
* Add Lyft as a user and contributor to operator
* Spark Operator Rework
* Reworking Restart-Policy
* Documentation update
* PR comments
* PR comments
* Ingress impl
* Ingress Tests + Updates
* go fmt
* PR Comments
* missing files
* AppId removal: Doc Update
* Doc update
* Delete UI/Ingress + Other minor changes
* Add PENDING_RETRY State
* PR comments
* PR comments
* Clean-up
* Update controller.go
* Add Terminal State
* Terminal State
* Spark improvements
* event type
* Events update
* Update controller.go
* Update controller.go
* PR Comments
* PR comments
* Support Best-effort Spec updates
* New State
* PR comments
* PR comments
* go fmt
* Docs update
* PR feedback
* PR Feedback
* PR comments
2018-11-19 15:25:55 -08:00
Yinan Li
c1ec30965a
Added support for creating a SparkApplication from a ScheduledSparkApplication
2018-10-05 10:15:34 -07:00
Riccardo Castellotti
17883cf7dc
add the KUBECONFIG check
2018-09-24 10:19:24 -07:00
Yinan Li
90e246faab
Fixed go import path
2018-09-13 12:32:58 -07:00
Piotr Mrowczynski
8592f34eed
Unify listing with status/event
2018-09-11 09:32:44 -07:00
Piotr Mrowczynski
5b9732cb51
Fix reader closing issue when err is nil
2018-09-04 21:03:45 -07:00
Yinan Li
f5b3b9aab4
Changed subcommand events to event for sparkctl
2018-08-09 10:36:28 -07:00
Piotr Mrówczyński
55b7b95b7a
Extend sparkctl to stream SparkApplication events ( #243 )
...
* Trigger events on driver/executor pending, running and unknown
* Extend sparkctl to stream SparkApplication events
2018-08-09 10:09:49 -07:00
Piotr Mrówczyński
8d95f535f7
Add s3 support for staging local dependencies in sparkctl #144 ( #179 )
...
* Add s3a support in sparkctl for staging local dependencies
Add aws sdk as dependency
* Adjust upload-to to go-cloud
Add documentation for staging local dependencies in s3a
2018-08-09 08:32:24 -07:00
Piotr Mrowczynski
c21d0c6ae4
Add PySpark support to sparkctl
2018-07-27 11:36:47 -07:00
Yinan Li
00c6a7fd58
Do not check restart eligibility if the application state has not changed
2018-07-10 23:30:03 -07:00
Piotr Mrowczynski
6179aacf7e
Adjust to kubernetes api v1.10 and client-go v7.0
2018-07-06 08:17:47 -07:00
Yinan Li
7e4c3a3270
Added support for streaming logs to sparkctl
2018-04-27 12:24:47 -07:00
Yinan Li
29c99bf1a0
Fixed a few typos in sparkctl
2018-02-07 15:50:36 -08:00
Yinan Li
2520f0547e
Ran go fmt on code
2018-01-29 12:54:47 -08:00
Yinan Li
56ec190de2
Added basic validation of SparkApplication spec in create
2018-01-29 12:09:40 -08:00
Yinan Li
91c1852714
Make sure local files are closed
2018-01-25 16:16:19 -08:00
Yinan Li
df9bbdc054
Added a flag to control whether to override files already exist remotely
2018-01-25 14:20:50 -08:00
Yinan Li
bf5b536e6d
Pretty printing executor status
2018-01-25 11:43:24 -08:00
Yinan Li
3373b30e6d
Added support for uploading local dependencies to GCS
2018-01-25 10:23:08 -08:00
Yinan Li
7d3aa7a39e
Updated to support the single image
2018-01-23 10:41:43 -08:00
Yinan Li
b6656a7dc5
Added support for fetching executor logs and some refactoring
2018-01-22 10:14:22 -08:00
Yinan Li
fa9483358c
Fixed import order
2018-01-21 14:22:56 -08:00
Yinan Li
d497960abb
Added a forward command for accessing the Spark UI
2018-01-21 12:23:45 -08:00
Yinan Li
736272ca36
Added a list command
2018-01-19 14:32:00 -08:00
Yinan Li
edf3417b52
Added basic implementation of log command of sparkctl
2018-01-19 12:53:41 -08:00
Yinan Li
8cbf3e7efe
More work on sparkctl
2018-01-19 12:28:17 -08:00
Yinan Li
abe1e3f255
Initial setup for sparkctl
2018-01-18 11:30:47 -08:00