FlinkSessionSpec
The specification to create a Flink session.
Syntax
{
"name": "string",
"runtime": "FLINK_1_17 | FLINK_1_18",
"jars": [
"string"
],
"plugins": [
{
"name": "string",
"jars": [
"string"
]
}
],
"flinkConfiguration": {
"string": "string"
},
"logConfiguration": {
"string": "string"
},
"jobManagerResource": {
"cpu": 0,
"memory": "string",
"ephemeralStorage": "string"
},
"taskManagerResource": {
"cpu": 0,
"memory": "string",
"ephemeralStorage": "string"
}
}
Type Definition
- Type
object
- Properties
jars
requiredA list of JAR files to be used by the Flink session.
- Type
array
- Items
- Type
string
- Type
- Type
plugins
requiredA list of plugins to be used by the Flink session.
- Type
array
- Items
The configuration of a Flink plugin.
- Schema
FlinkPlugin
- Schema
- Type
jobManagerResource
requiredThe resource configuration of the Flink JobManager containers.
- Schema
ContainerResource
- Schema
taskManagerResource
requiredThe resource configuration of the Flink TaskManager containers.
- Schema
ContainerResource
- Schema