FuyaoLi2017 edited a comment on pull request #1:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/1#issuecomment-1041062506
For session cluster, maybe we can consider some job level control? This
`sessionClusterMaintainedJobs` mentioned below is a map containing arbitrary
number of session job specs.
I am not sure if this will add much value or not. We can have some
discussion over this. This is also not top priority for this very first version.
```
sessionClusterMaintainedJobs:
type: object
additionalProperties:
type: object
properties:
artifactoryJarHeader:
type: array
nullable: true
items:
type: string
artifactoryJarUri:
type: string
savepointGeneration:
type: integer
minimum: 0
parallelism:
type: integer
minimum: 1
allowNonRestoredState:
type: boolean
nullable: true
drainFlag:
type: boolean
nullable: true
savepointsDir:
type: string
nullable: true
fromSavepoint:
type: string
nullable: true
autoSavepointSeconds:
type: integer
minimum: 10 # Generally, this value is recommended to be
significantly larger than RECONCILE_INTERVAL_MS (the reconcile period) in
FlinkApplicationController
jobAction:
type: string
enum: [stop, cancel, run]
mainArgs:
type: array
nullable: true
items:
type: string
entryClass:
type: string
nullable: true
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
