-
Notifications
You must be signed in to change notification settings - Fork 117
Reorganize packages between v1 work and v2 work #220
Reorganize packages between v1 work and v2 work #220
Conversation
…es' into submission-v2-file-server
|
Note that this is merging into #212. @ash211 @foxish @erikerlandson |
We still want to post them because in the future we can use these credentials to monitor the API server and handle cleaning up the data accordingly.
| uploadedJarsBase64Contents: TarGzippedData, | ||
| uploadedFilesBase64Contents: TarGzippedData) extends SubmitRestProtocolRequest { | ||
| @JsonIgnore | ||
| override val messageType: String = s"kubernetes.v1.${Utils.getFormattedClassName(this)}" |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
is this to support compat across a span of versions? Maybe a new rest service with an old launcher?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
This is necessary due to the fact that SubmitRestProtocolRequest expects all subclasses to live in the package org.apache.spark.deploy.rest. The deserialization fails otherwise. This is a workaround to keep the package names consistent for now until we remove this class entirely.
…server' into submission-v2-file-server
…server' into split-v1-and-v2-submission-packages
ash211
left a comment
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM though I'd rather merge the dependent PR before this one
|
Will merge into |
…packages Conflicts: resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/rest/kubernetes/v2/ResourceStagingService.scala resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/rest/kubernetes/v2/ResourceStagingServiceImpl.scala resource-managers/kubernetes/core/src/test/scala/org/apache/spark/deploy/rest/kubernetes/v2/ResourceStagingServerSuite.scala resource-managers/kubernetes/core/src/test/scala/org/apache/spark/deploy/rest/kubernetes/v2/ResourceStagingServiceImplSuite.scala
* Staging server for receiving application dependencies. * Move packages around to split between v1 work and v2 work * Add unit test for file writing * Remove unnecessary main * Add back license header * Minor fixes * Fix integration test with renamed package for client. Fix scalastyle. * Force json serialization to consider the different package. * Revert extraneous log * Fix scalastyle * Remove getting credentials from the API We still want to post them because in the future we can use these credentials to monitor the API server and handle cleaning up the data accordingly. * Generalize to resource staging server outside of Spark * Update code documentation * Val instead of var * Fix build * Fix naming, remove unused import * Move suites from integration test package to core * Use TrieMap instead of locks * Address comments * Fix imports * Change paths, use POST instead of PUT * Use a resource identifier as well as a resource secret
) * Staging server for receiving application dependencies. * Move packages around to split between v1 work and v2 work * Add unit test for file writing * Remove unnecessary main * Add back license header * Minor fixes * Fix integration test with renamed package for client. Fix scalastyle. * Force json serialization to consider the different package. * Revert extraneous log * Fix scalastyle * Remove getting credentials from the API We still want to post them because in the future we can use these credentials to monitor the API server and handle cleaning up the data accordingly. * Generalize to resource staging server outside of Spark * Update code documentation * Val instead of var * Fix build * Fix naming, remove unused import * Move suites from integration test package to core * Use TrieMap instead of locks * Address comments * Fix imports * Change paths, use POST instead of PUT * Use a resource identifier as well as a resource secret
Move packages around to split between v1 work and v2 work. This will make it easier to develop submission v2 incrementally without removing what we already have for v1.