published on Wednesday, Sep 23, 2026 by Pulumi
published on Wednesday, Sep 23, 2026 by Pulumi
Creates and manages the deployment of an Aiven for Apache Flink® jar application. If this resource is missing (for example, after a service power off), it’s removed from the state and a new create plan is generated.
Beta resource in limited availability This feature is in the limited availability stage and may change without notice. To enable this feature, contact the sales team. Once it’s enabled, set the
PROVIDER_AIVEN_ENABLE_BETAenvironment variable to use the resource.
Example Usage
import * as pulumi from "@pulumi/pulumi";
import * as aiven from "@pulumi/aiven";
const example = new aiven.FlinkJarApplicationDeployment("example", {
project: "my-project",
serviceName: "my-application",
applicationId: "foo",
versionId: "543e420d-aa63-43e8-b8e8-294a78c600e7",
entryClass: "com.example.MyFlinkJob",
parallelism: 1,
programArgs: ["example-argument"],
restartEnabled: true,
startingSavepoint: "path/to/savepoint",
});
import pulumi
import pulumi_aiven as aiven
example = aiven.FlinkJarApplicationDeployment("example",
project="my-project",
service_name="my-application",
application_id="foo",
version_id="543e420d-aa63-43e8-b8e8-294a78c600e7",
entry_class="com.example.MyFlinkJob",
parallelism=1,
program_args=["example-argument"],
restart_enabled=True,
starting_savepoint="path/to/savepoint")
package main
import (
"github.com/pulumi/pulumi-aiven/sdk/v6/go/aiven"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)
func main() {
pulumi.Run(func(ctx *pulumi.Context) error {
_, err := aiven.NewFlinkJarApplicationDeployment(ctx, "example", &aiven.FlinkJarApplicationDeploymentArgs{
Project: pulumi.String("my-project"),
ServiceName: pulumi.String("my-application"),
ApplicationId: pulumi.String("foo"),
VersionId: pulumi.String("543e420d-aa63-43e8-b8e8-294a78c600e7"),
EntryClass: pulumi.String("com.example.MyFlinkJob"),
Parallelism: pulumi.Int(1),
ProgramArgs: pulumi.StringArray{
pulumi.String("example-argument"),
},
RestartEnabled: pulumi.Bool(true),
StartingSavepoint: pulumi.String("path/to/savepoint"),
})
if err != nil {
return err
}
return nil
})
}
using System.Collections.Generic;
using System.Linq;
using Pulumi;
using Aiven = Pulumi.Aiven;
return await Deployment.RunAsync(() =>
{
var example = new Aiven.FlinkJarApplicationDeployment("example", new()
{
Project = "my-project",
ServiceName = "my-application",
ApplicationId = "foo",
VersionId = "543e420d-aa63-43e8-b8e8-294a78c600e7",
EntryClass = "com.example.MyFlinkJob",
Parallelism = 1,
ProgramArgs = new[]
{
"example-argument",
},
RestartEnabled = true,
StartingSavepoint = "path/to/savepoint",
});
});
package generated_program;
import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.aiven.FlinkJarApplicationDeployment;
import com.pulumi.aiven.FlinkJarApplicationDeploymentArgs;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Map;
import java.io.File;
import java.nio.file.Files;
import java.nio.file.Paths;
public class App {
public static void main(String[] args) {
Pulumi.run(App::stack);
}
public static void stack(Context ctx) {
var example = new FlinkJarApplicationDeployment("example", FlinkJarApplicationDeploymentArgs.builder()
.project("my-project")
.serviceName("my-application")
.applicationId("foo")
.versionId("543e420d-aa63-43e8-b8e8-294a78c600e7")
.entryClass("com.example.MyFlinkJob")
.parallelism(1)
.programArgs("example-argument")
.restartEnabled(true)
.startingSavepoint("path/to/savepoint")
.build());
}
}
resources:
example:
type: aiven:FlinkJarApplicationDeployment
properties:
project: my-project
serviceName: my-application
applicationId: foo
versionId: 543e420d-aa63-43e8-b8e8-294a78c600e7
entryClass: com.example.MyFlinkJob
parallelism: 1 # Force new
programArgs: # Force new
- example-argument
restartEnabled: true # Force new
startingSavepoint: path/to/savepoint
pulumi {
required_providers {
aiven = {
source = "pulumi/aiven"
}
}
}
resource "aiven_flinkjarapplicationdeployment" "example" {
project = "my-project"
service_name = "my-application"
application_id = "foo"
version_id = "543e420d-aa63-43e8-b8e8-294a78c600e7"
entry_class = "com.example.MyFlinkJob"
parallelism = 1 // Force new
program_args = ["example-argument"] // Force new
restart_enabled = true // Force new
starting_savepoint = "path/to/savepoint"
}
Create FlinkJarApplicationDeployment Resource
Resources are created with functions called constructors. To learn more about declaring and configuring resources, see Resources.
Constructor syntax
new FlinkJarApplicationDeployment(name: string, args: FlinkJarApplicationDeploymentArgs, opts?: CustomResourceOptions);@overload
def FlinkJarApplicationDeployment(resource_name: str,
args: FlinkJarApplicationDeploymentArgs,
opts: Optional[ResourceOptions] = None)
@overload
def FlinkJarApplicationDeployment(resource_name: str,
opts: Optional[ResourceOptions] = None,
application_id: Optional[str] = None,
project: Optional[str] = None,
service_name: Optional[str] = None,
version_id: Optional[str] = None,
entry_class: Optional[str] = None,
parallelism: Optional[int] = None,
program_args: Optional[Sequence[str]] = None,
restart_enabled: Optional[bool] = None,
starting_savepoint: Optional[str] = None,
timeouts: Optional[FlinkJarApplicationDeploymentTimeoutsArgs] = None)func NewFlinkJarApplicationDeployment(ctx *Context, name string, args FlinkJarApplicationDeploymentArgs, opts ...ResourceOption) (*FlinkJarApplicationDeployment, error)public FlinkJarApplicationDeployment(string name, FlinkJarApplicationDeploymentArgs args, CustomResourceOptions? opts = null)
public FlinkJarApplicationDeployment(String name, FlinkJarApplicationDeploymentArgs args)
public FlinkJarApplicationDeployment(String name, FlinkJarApplicationDeploymentArgs args, CustomResourceOptions options)
type: aiven:FlinkJarApplicationDeployment
properties: # The arguments to resource properties.
options: # Bag of options to control resource's behavior.
resource "aiven_flink_jar_application_deployment" "name" {
# resource properties
}Parameters
- name string
- The unique name of the resource.
- args FlinkJarApplicationDeploymentArgs
- The arguments to resource properties.
- opts CustomResourceOptions
- Bag of options to control resource's behavior.
- resource_name str
- The unique name of the resource.
- args FlinkJarApplicationDeploymentArgs
- The arguments to resource properties.
- opts ResourceOptions
- Bag of options to control resource's behavior.
- ctx Context
- Context object for the current deployment.
- name string
- The unique name of the resource.
- args FlinkJarApplicationDeploymentArgs
- The arguments to resource properties.
- opts ResourceOption
- Bag of options to control resource's behavior.
- name string
- The unique name of the resource.
- args FlinkJarApplicationDeploymentArgs
- The arguments to resource properties.
- opts CustomResourceOptions
- Bag of options to control resource's behavior.
- name String
- The unique name of the resource.
- args FlinkJarApplicationDeploymentArgs
- The arguments to resource properties.
- options CustomResourceOptions
- Bag of options to control resource's behavior.
Constructor example
The following reference example uses placeholder values for all input properties.
var flinkJarApplicationDeploymentResource = new Aiven.FlinkJarApplicationDeployment("flinkJarApplicationDeploymentResource", new()
{
ApplicationId = "string",
Project = "string",
ServiceName = "string",
VersionId = "string",
EntryClass = "string",
Parallelism = 0,
ProgramArgs = new[]
{
"string",
},
RestartEnabled = false,
StartingSavepoint = "string",
Timeouts = new Aiven.Inputs.FlinkJarApplicationDeploymentTimeoutsArgs
{
Create = "string",
Delete = "string",
Read = "string",
Update = "string",
},
});
example, err := aiven.NewFlinkJarApplicationDeployment(ctx, "flinkJarApplicationDeploymentResource", &aiven.FlinkJarApplicationDeploymentArgs{
ApplicationId: pulumi.String("string"),
Project: pulumi.String("string"),
ServiceName: pulumi.String("string"),
VersionId: pulumi.String("string"),
EntryClass: pulumi.String("string"),
Parallelism: pulumi.Int(0),
ProgramArgs: pulumi.StringArray{
pulumi.String("string"),
},
RestartEnabled: pulumi.Bool(false),
StartingSavepoint: pulumi.String("string"),
Timeouts: &aiven.FlinkJarApplicationDeploymentTimeoutsArgs{
Create: pulumi.String("string"),
Delete: pulumi.String("string"),
Read: pulumi.String("string"),
Update: pulumi.String("string"),
},
})
resource "aiven_flink_jar_application_deployment" "flinkJarApplicationDeploymentResource" {
lifecycle {
create_before_destroy = true
}
application_id = "string"
project = "string"
service_name = "string"
version_id = "string"
entry_class = "string"
parallelism = 0
program_args = ["string"]
restart_enabled = false
starting_savepoint = "string"
timeouts = {
create = "string"
delete = "string"
read = "string"
update = "string"
}
}
var flinkJarApplicationDeploymentResource = new FlinkJarApplicationDeployment("flinkJarApplicationDeploymentResource", FlinkJarApplicationDeploymentArgs.builder()
.applicationId("string")
.project("string")
.serviceName("string")
.versionId("string")
.entryClass("string")
.parallelism(0)
.programArgs("string")
.restartEnabled(false)
.startingSavepoint("string")
.timeouts(FlinkJarApplicationDeploymentTimeoutsArgs.builder()
.create("string")
.delete("string")
.read("string")
.update("string")
.build())
.build());
flink_jar_application_deployment_resource = aiven.FlinkJarApplicationDeployment("flinkJarApplicationDeploymentResource",
application_id="string",
project="string",
service_name="string",
version_id="string",
entry_class="string",
parallelism=0,
program_args=["string"],
restart_enabled=False,
starting_savepoint="string",
timeouts={
"create": "string",
"delete": "string",
"read": "string",
"update": "string",
})
const flinkJarApplicationDeploymentResource = new aiven.FlinkJarApplicationDeployment("flinkJarApplicationDeploymentResource", {
applicationId: "string",
project: "string",
serviceName: "string",
versionId: "string",
entryClass: "string",
parallelism: 0,
programArgs: ["string"],
restartEnabled: false,
startingSavepoint: "string",
timeouts: {
create: "string",
"delete": "string",
read: "string",
update: "string",
},
});
type: aiven:FlinkJarApplicationDeployment
properties:
applicationId: string
entryClass: string
parallelism: 0
programArgs:
- string
project: string
restartEnabled: false
serviceName: string
startingSavepoint: string
timeouts:
create: string
delete: string
read: string
update: string
versionId: string
FlinkJarApplicationDeployment Resource Properties
To learn more about resource properties and how to use them, see Inputs and Outputs in the Architecture and Concepts docs.
Inputs
In Python, inputs that are objects can be passed either as argument classes or as dictionary literals.
The FlinkJarApplicationDeployment resource accepts the following input properties:
- Application
Id string - Application Id. Changing this property forces recreation of the resource.
- Project string
- Project name. Changing this property forces recreation of the resource.
- Service
Name string - Service name. Changing this property forces recreation of the resource.
- Version
Id string - ApplicationVersion ID. Length must be exactly
36. Changing this property forces recreation of the resource. - Entry
Class string - The fully qualified name of the entry class to pass during Flink job submission through the entryClass parameter. Length must be between
1and128. Changing this property forces recreation of the resource. - Parallelism int
- Reading of Flink parallel execution documentation is recommended before setting this value to other than 1. Please do not set this value higher than (total number of nodes x numberoftask_slots), or every new job created will fail. Value must be between
1and128. Changing this property forces recreation of the resource. - Program
Args List<string> - Arguments to pass during Flink job submission through the programArgsList parameter. Changing this property forces recreation of the resource.
- Restart
Enabled bool - Specifies whether a Flink Job is restarted in case it fails. Changing this property forces recreation of the resource.
- Starting
Savepoint string - Job savepoint. Length must be between
1and2048. Changing this property forces recreation of the resource. - Timeouts
Flink
Jar Application Deployment Timeouts
- Application
Id string - Application Id. Changing this property forces recreation of the resource.
- Project string
- Project name. Changing this property forces recreation of the resource.
- Service
Name string - Service name. Changing this property forces recreation of the resource.
- Version
Id string - ApplicationVersion ID. Length must be exactly
36. Changing this property forces recreation of the resource. - Entry
Class string - The fully qualified name of the entry class to pass during Flink job submission through the entryClass parameter. Length must be between
1and128. Changing this property forces recreation of the resource. - Parallelism int
- Reading of Flink parallel execution documentation is recommended before setting this value to other than 1. Please do not set this value higher than (total number of nodes x numberoftask_slots), or every new job created will fail. Value must be between
1and128. Changing this property forces recreation of the resource. - Program
Args []string - Arguments to pass during Flink job submission through the programArgsList parameter. Changing this property forces recreation of the resource.
- Restart
Enabled bool - Specifies whether a Flink Job is restarted in case it fails. Changing this property forces recreation of the resource.
- Starting
Savepoint string - Job savepoint. Length must be between
1and2048. Changing this property forces recreation of the resource. - Timeouts
Flink
Jar Application Deployment Timeouts Args
- application_
id string - Application Id. Changing this property forces recreation of the resource.
- project string
- Project name. Changing this property forces recreation of the resource.
- service_
name string - Service name. Changing this property forces recreation of the resource.
- version_
id string - ApplicationVersion ID. Length must be exactly
36. Changing this property forces recreation of the resource. - entry_
class string - The fully qualified name of the entry class to pass during Flink job submission through the entryClass parameter. Length must be between
1and128. Changing this property forces recreation of the resource. - parallelism number
- Reading of Flink parallel execution documentation is recommended before setting this value to other than 1. Please do not set this value higher than (total number of nodes x numberoftask_slots), or every new job created will fail. Value must be between
1and128. Changing this property forces recreation of the resource. - program_
args list(string) - Arguments to pass during Flink job submission through the programArgsList parameter. Changing this property forces recreation of the resource.
- restart_
enabled bool - Specifies whether a Flink Job is restarted in case it fails. Changing this property forces recreation of the resource.
- starting_
savepoint string - Job savepoint. Length must be between
1and2048. Changing this property forces recreation of the resource. - timeouts object
- application
Id String - Application Id. Changing this property forces recreation of the resource.
- project String
- Project name. Changing this property forces recreation of the resource.
- service
Name String - Service name. Changing this property forces recreation of the resource.
- version
Id String - ApplicationVersion ID. Length must be exactly
36. Changing this property forces recreation of the resource. - entry
Class String - The fully qualified name of the entry class to pass during Flink job submission through the entryClass parameter. Length must be between
1and128. Changing this property forces recreation of the resource. - parallelism Integer
- Reading of Flink parallel execution documentation is recommended before setting this value to other than 1. Please do not set this value higher than (total number of nodes x numberoftask_slots), or every new job created will fail. Value must be between
1and128. Changing this property forces recreation of the resource. - program
Args List<String> - Arguments to pass during Flink job submission through the programArgsList parameter. Changing this property forces recreation of the resource.
- restart
Enabled Boolean - Specifies whether a Flink Job is restarted in case it fails. Changing this property forces recreation of the resource.
- starting
Savepoint String - Job savepoint. Length must be between
1and2048. Changing this property forces recreation of the resource. - timeouts
Flink
Jar Application Deployment Timeouts
- application
Id string - Application Id. Changing this property forces recreation of the resource.
- project string
- Project name. Changing this property forces recreation of the resource.
- service
Name string - Service name. Changing this property forces recreation of the resource.
- version
Id string - ApplicationVersion ID. Length must be exactly
36. Changing this property forces recreation of the resource. - entry
Class string - The fully qualified name of the entry class to pass during Flink job submission through the entryClass parameter. Length must be between
1and128. Changing this property forces recreation of the resource. - parallelism number
- Reading of Flink parallel execution documentation is recommended before setting this value to other than 1. Please do not set this value higher than (total number of nodes x numberoftask_slots), or every new job created will fail. Value must be between
1and128. Changing this property forces recreation of the resource. - program
Args string[] - Arguments to pass during Flink job submission through the programArgsList parameter. Changing this property forces recreation of the resource.
- restart
Enabled boolean - Specifies whether a Flink Job is restarted in case it fails. Changing this property forces recreation of the resource.
- starting
Savepoint string - Job savepoint. Length must be between
1and2048. Changing this property forces recreation of the resource. - timeouts
Flink
Jar Application Deployment Timeouts
- application_
id str - Application Id. Changing this property forces recreation of the resource.
- project str
- Project name. Changing this property forces recreation of the resource.
- service_
name str - Service name. Changing this property forces recreation of the resource.
- version_
id str - ApplicationVersion ID. Length must be exactly
36. Changing this property forces recreation of the resource. - entry_
class str - The fully qualified name of the entry class to pass during Flink job submission through the entryClass parameter. Length must be between
1and128. Changing this property forces recreation of the resource. - parallelism int
- Reading of Flink parallel execution documentation is recommended before setting this value to other than 1. Please do not set this value higher than (total number of nodes x numberoftask_slots), or every new job created will fail. Value must be between
1and128. Changing this property forces recreation of the resource. - program_
args Sequence[str] - Arguments to pass during Flink job submission through the programArgsList parameter. Changing this property forces recreation of the resource.
- restart_
enabled bool - Specifies whether a Flink Job is restarted in case it fails. Changing this property forces recreation of the resource.
- starting_
savepoint str - Job savepoint. Length must be between
1and2048. Changing this property forces recreation of the resource. - timeouts
Flink
Jar Application Deployment Timeouts Args
- application
Id String - Application Id. Changing this property forces recreation of the resource.
- project String
- Project name. Changing this property forces recreation of the resource.
- service
Name String - Service name. Changing this property forces recreation of the resource.
- version
Id String - ApplicationVersion ID. Length must be exactly
36. Changing this property forces recreation of the resource. - entry
Class String - The fully qualified name of the entry class to pass during Flink job submission through the entryClass parameter. Length must be between
1and128. Changing this property forces recreation of the resource. - parallelism Number
- Reading of Flink parallel execution documentation is recommended before setting this value to other than 1. Please do not set this value higher than (total number of nodes x numberoftask_slots), or every new job created will fail. Value must be between
1and128. Changing this property forces recreation of the resource. - program
Args List<String> - Arguments to pass during Flink job submission through the programArgsList parameter. Changing this property forces recreation of the resource.
- restart
Enabled Boolean - Specifies whether a Flink Job is restarted in case it fails. Changing this property forces recreation of the resource.
- starting
Savepoint String - Job savepoint. Length must be between
1and2048. Changing this property forces recreation of the resource. - timeouts Property Map
Outputs
All input properties are implicitly available as output properties. Additionally, the FlinkJarApplicationDeployment resource produces the following output properties:
- Created
At string - The creation timestamp of this entity in ISO 8601 format, always in UTC.
- Created
By string - The creator of this entity.
- Deployment
Id string - Deployment ID.
- Error
Msg string - Error message describing what caused deployment to fail.
- Id string
- The provider-assigned unique ID for this managed resource.
- Job
Id string - Job ID.
- Last
Savepoint string - Job savepoint.
- Status string
- Deployment status. The possible values are
CANCELED,CANCELLING,CANCELLING_REQUESTED,CREATED,DELETE_REQUESTED,DELETING,FAILED,FAILING,FINISHED,INITIALIZING,RECONCILING,RESTARTING,RUNNING,SAVING,SAVING_AND_STOP,SAVING_AND_STOP_REQUESTEDandSUSPENDED.
- Created
At string - The creation timestamp of this entity in ISO 8601 format, always in UTC.
- Created
By string - The creator of this entity.
- Deployment
Id string - Deployment ID.
- Error
Msg string - Error message describing what caused deployment to fail.
- Id string
- The provider-assigned unique ID for this managed resource.
- Job
Id string - Job ID.
- Last
Savepoint string - Job savepoint.
- Status string
- Deployment status. The possible values are
CANCELED,CANCELLING,CANCELLING_REQUESTED,CREATED,DELETE_REQUESTED,DELETING,FAILED,FAILING,FINISHED,INITIALIZING,RECONCILING,RESTARTING,RUNNING,SAVING,SAVING_AND_STOP,SAVING_AND_STOP_REQUESTEDandSUSPENDED.
- created_
at string - The creation timestamp of this entity in ISO 8601 format, always in UTC.
- created_
by string - The creator of this entity.
- deployment_
id string - Deployment ID.
- error_
msg string - Error message describing what caused deployment to fail.
- id string
- The provider-assigned unique ID for this managed resource.
- job_
id string - Job ID.
- last_
savepoint string - Job savepoint.
- status string
- Deployment status. The possible values are
CANCELED,CANCELLING,CANCELLING_REQUESTED,CREATED,DELETE_REQUESTED,DELETING,FAILED,FAILING,FINISHED,INITIALIZING,RECONCILING,RESTARTING,RUNNING,SAVING,SAVING_AND_STOP,SAVING_AND_STOP_REQUESTEDandSUSPENDED.
- created
At String - The creation timestamp of this entity in ISO 8601 format, always in UTC.
- created
By String - The creator of this entity.
- deployment
Id String - Deployment ID.
- error
Msg String - Error message describing what caused deployment to fail.
- id String
- The provider-assigned unique ID for this managed resource.
- job
Id String - Job ID.
- last
Savepoint String - Job savepoint.
- status String
- Deployment status. The possible values are
CANCELED,CANCELLING,CANCELLING_REQUESTED,CREATED,DELETE_REQUESTED,DELETING,FAILED,FAILING,FINISHED,INITIALIZING,RECONCILING,RESTARTING,RUNNING,SAVING,SAVING_AND_STOP,SAVING_AND_STOP_REQUESTEDandSUSPENDED.
- created
At string - The creation timestamp of this entity in ISO 8601 format, always in UTC.
- created
By string - The creator of this entity.
- deployment
Id string - Deployment ID.
- error
Msg string - Error message describing what caused deployment to fail.
- id string
- The provider-assigned unique ID for this managed resource.
- job
Id string - Job ID.
- last
Savepoint string - Job savepoint.
- status string
- Deployment status. The possible values are
CANCELED,CANCELLING,CANCELLING_REQUESTED,CREATED,DELETE_REQUESTED,DELETING,FAILED,FAILING,FINISHED,INITIALIZING,RECONCILING,RESTARTING,RUNNING,SAVING,SAVING_AND_STOP,SAVING_AND_STOP_REQUESTEDandSUSPENDED.
- created_
at str - The creation timestamp of this entity in ISO 8601 format, always in UTC.
- created_
by str - The creator of this entity.
- deployment_
id str - Deployment ID.
- error_
msg str - Error message describing what caused deployment to fail.
- id str
- The provider-assigned unique ID for this managed resource.
- job_
id str - Job ID.
- last_
savepoint str - Job savepoint.
- status str
- Deployment status. The possible values are
CANCELED,CANCELLING,CANCELLING_REQUESTED,CREATED,DELETE_REQUESTED,DELETING,FAILED,FAILING,FINISHED,INITIALIZING,RECONCILING,RESTARTING,RUNNING,SAVING,SAVING_AND_STOP,SAVING_AND_STOP_REQUESTEDandSUSPENDED.
- created
At String - The creation timestamp of this entity in ISO 8601 format, always in UTC.
- created
By String - The creator of this entity.
- deployment
Id String - Deployment ID.
- error
Msg String - Error message describing what caused deployment to fail.
- id String
- The provider-assigned unique ID for this managed resource.
- job
Id String - Job ID.
- last
Savepoint String - Job savepoint.
- status String
- Deployment status. The possible values are
CANCELED,CANCELLING,CANCELLING_REQUESTED,CREATED,DELETE_REQUESTED,DELETING,FAILED,FAILING,FINISHED,INITIALIZING,RECONCILING,RESTARTING,RUNNING,SAVING,SAVING_AND_STOP,SAVING_AND_STOP_REQUESTEDandSUSPENDED.
Look up Existing FlinkJarApplicationDeployment Resource
Get an existing FlinkJarApplicationDeployment resource’s state with the given name, ID, and optional extra properties used to qualify the lookup.
public static get(name: string, id: Input<ID>, state?: FlinkJarApplicationDeploymentState, opts?: CustomResourceOptions): FlinkJarApplicationDeployment@staticmethod
def get(resource_name: str,
id: str,
opts: Optional[ResourceOptions] = None,
application_id: Optional[str] = None,
created_at: Optional[str] = None,
created_by: Optional[str] = None,
deployment_id: Optional[str] = None,
entry_class: Optional[str] = None,
error_msg: Optional[str] = None,
job_id: Optional[str] = None,
last_savepoint: Optional[str] = None,
parallelism: Optional[int] = None,
program_args: Optional[Sequence[str]] = None,
project: Optional[str] = None,
restart_enabled: Optional[bool] = None,
service_name: Optional[str] = None,
starting_savepoint: Optional[str] = None,
status: Optional[str] = None,
timeouts: Optional[FlinkJarApplicationDeploymentTimeoutsArgs] = None,
version_id: Optional[str] = None) -> FlinkJarApplicationDeploymentfunc GetFlinkJarApplicationDeployment(ctx *Context, name string, id IDInput, state *FlinkJarApplicationDeploymentState, opts ...ResourceOption) (*FlinkJarApplicationDeployment, error)public static FlinkJarApplicationDeployment Get(string name, Input<string> id, FlinkJarApplicationDeploymentState? state, CustomResourceOptions? opts = null)public static FlinkJarApplicationDeployment get(String name, Output<String> id, FlinkJarApplicationDeploymentState state, CustomResourceOptions options)resources: _: type: aiven:FlinkJarApplicationDeployment get: id: ${id}import {
to = aiven_flink_jar_application_deployment.example
id = "${id}"
}
- name
- The unique name of the resulting resource.
- id
- The unique provider ID of the resource to lookup.
- state
- Any extra arguments used during the lookup.
- opts
- A bag of options that control this resource's behavior.
- resource_name
- The unique name of the resulting resource.
- id
- The unique provider ID of the resource to lookup.
- name
- The unique name of the resulting resource.
- id
- The unique provider ID of the resource to lookup.
- state
- Any extra arguments used during the lookup.
- opts
- A bag of options that control this resource's behavior.
- name
- The unique name of the resulting resource.
- id
- The unique provider ID of the resource to lookup.
- state
- Any extra arguments used during the lookup.
- opts
- A bag of options that control this resource's behavior.
- name
- The unique name of the resulting resource.
- id
- The unique provider ID of the resource to lookup.
- state
- Any extra arguments used during the lookup.
- opts
- A bag of options that control this resource's behavior.
- Application
Id string - Application Id. Changing this property forces recreation of the resource.
- Created
At string - The creation timestamp of this entity in ISO 8601 format, always in UTC.
- Created
By string - The creator of this entity.
- Deployment
Id string - Deployment ID.
- Entry
Class string - The fully qualified name of the entry class to pass during Flink job submission through the entryClass parameter. Length must be between
1and128. Changing this property forces recreation of the resource. - Error
Msg string - Error message describing what caused deployment to fail.
- Job
Id string - Job ID.
- Last
Savepoint string - Job savepoint.
- Parallelism int
- Reading of Flink parallel execution documentation is recommended before setting this value to other than 1. Please do not set this value higher than (total number of nodes x numberoftask_slots), or every new job created will fail. Value must be between
1and128. Changing this property forces recreation of the resource. - Program
Args List<string> - Arguments to pass during Flink job submission through the programArgsList parameter. Changing this property forces recreation of the resource.
- Project string
- Project name. Changing this property forces recreation of the resource.
- Restart
Enabled bool - Specifies whether a Flink Job is restarted in case it fails. Changing this property forces recreation of the resource.
- Service
Name string - Service name. Changing this property forces recreation of the resource.
- Starting
Savepoint string - Job savepoint. Length must be between
1and2048. Changing this property forces recreation of the resource. - Status string
- Deployment status. The possible values are
CANCELED,CANCELLING,CANCELLING_REQUESTED,CREATED,DELETE_REQUESTED,DELETING,FAILED,FAILING,FINISHED,INITIALIZING,RECONCILING,RESTARTING,RUNNING,SAVING,SAVING_AND_STOP,SAVING_AND_STOP_REQUESTEDandSUSPENDED. - Timeouts
Flink
Jar Application Deployment Timeouts - Version
Id string - ApplicationVersion ID. Length must be exactly
36. Changing this property forces recreation of the resource.
- Application
Id string - Application Id. Changing this property forces recreation of the resource.
- Created
At string - The creation timestamp of this entity in ISO 8601 format, always in UTC.
- Created
By string - The creator of this entity.
- Deployment
Id string - Deployment ID.
- Entry
Class string - The fully qualified name of the entry class to pass during Flink job submission through the entryClass parameter. Length must be between
1and128. Changing this property forces recreation of the resource. - Error
Msg string - Error message describing what caused deployment to fail.
- Job
Id string - Job ID.
- Last
Savepoint string - Job savepoint.
- Parallelism int
- Reading of Flink parallel execution documentation is recommended before setting this value to other than 1. Please do not set this value higher than (total number of nodes x numberoftask_slots), or every new job created will fail. Value must be between
1and128. Changing this property forces recreation of the resource. - Program
Args []string - Arguments to pass during Flink job submission through the programArgsList parameter. Changing this property forces recreation of the resource.
- Project string
- Project name. Changing this property forces recreation of the resource.
- Restart
Enabled bool - Specifies whether a Flink Job is restarted in case it fails. Changing this property forces recreation of the resource.
- Service
Name string - Service name. Changing this property forces recreation of the resource.
- Starting
Savepoint string - Job savepoint. Length must be between
1and2048. Changing this property forces recreation of the resource. - Status string
- Deployment status. The possible values are
CANCELED,CANCELLING,CANCELLING_REQUESTED,CREATED,DELETE_REQUESTED,DELETING,FAILED,FAILING,FINISHED,INITIALIZING,RECONCILING,RESTARTING,RUNNING,SAVING,SAVING_AND_STOP,SAVING_AND_STOP_REQUESTEDandSUSPENDED. - Timeouts
Flink
Jar Application Deployment Timeouts Args - Version
Id string - ApplicationVersion ID. Length must be exactly
36. Changing this property forces recreation of the resource.
- application_
id string - Application Id. Changing this property forces recreation of the resource.
- created_
at string - The creation timestamp of this entity in ISO 8601 format, always in UTC.
- created_
by string - The creator of this entity.
- deployment_
id string - Deployment ID.
- entry_
class string - The fully qualified name of the entry class to pass during Flink job submission through the entryClass parameter. Length must be between
1and128. Changing this property forces recreation of the resource. - error_
msg string - Error message describing what caused deployment to fail.
- job_
id string - Job ID.
- last_
savepoint string - Job savepoint.
- parallelism number
- Reading of Flink parallel execution documentation is recommended before setting this value to other than 1. Please do not set this value higher than (total number of nodes x numberoftask_slots), or every new job created will fail. Value must be between
1and128. Changing this property forces recreation of the resource. - program_
args list(string) - Arguments to pass during Flink job submission through the programArgsList parameter. Changing this property forces recreation of the resource.
- project string
- Project name. Changing this property forces recreation of the resource.
- restart_
enabled bool - Specifies whether a Flink Job is restarted in case it fails. Changing this property forces recreation of the resource.
- service_
name string - Service name. Changing this property forces recreation of the resource.
- starting_
savepoint string - Job savepoint. Length must be between
1and2048. Changing this property forces recreation of the resource. - status string
- Deployment status. The possible values are
CANCELED,CANCELLING,CANCELLING_REQUESTED,CREATED,DELETE_REQUESTED,DELETING,FAILED,FAILING,FINISHED,INITIALIZING,RECONCILING,RESTARTING,RUNNING,SAVING,SAVING_AND_STOP,SAVING_AND_STOP_REQUESTEDandSUSPENDED. - timeouts object
- version_
id string - ApplicationVersion ID. Length must be exactly
36. Changing this property forces recreation of the resource.
- application
Id String - Application Id. Changing this property forces recreation of the resource.
- created
At String - The creation timestamp of this entity in ISO 8601 format, always in UTC.
- created
By String - The creator of this entity.
- deployment
Id String - Deployment ID.
- entry
Class String - The fully qualified name of the entry class to pass during Flink job submission through the entryClass parameter. Length must be between
1and128. Changing this property forces recreation of the resource. - error
Msg String - Error message describing what caused deployment to fail.
- job
Id String - Job ID.
- last
Savepoint String - Job savepoint.
- parallelism Integer
- Reading of Flink parallel execution documentation is recommended before setting this value to other than 1. Please do not set this value higher than (total number of nodes x numberoftask_slots), or every new job created will fail. Value must be between
1and128. Changing this property forces recreation of the resource. - program
Args List<String> - Arguments to pass during Flink job submission through the programArgsList parameter. Changing this property forces recreation of the resource.
- project String
- Project name. Changing this property forces recreation of the resource.
- restart
Enabled Boolean - Specifies whether a Flink Job is restarted in case it fails. Changing this property forces recreation of the resource.
- service
Name String - Service name. Changing this property forces recreation of the resource.
- starting
Savepoint String - Job savepoint. Length must be between
1and2048. Changing this property forces recreation of the resource. - status String
- Deployment status. The possible values are
CANCELED,CANCELLING,CANCELLING_REQUESTED,CREATED,DELETE_REQUESTED,DELETING,FAILED,FAILING,FINISHED,INITIALIZING,RECONCILING,RESTARTING,RUNNING,SAVING,SAVING_AND_STOP,SAVING_AND_STOP_REQUESTEDandSUSPENDED. - timeouts
Flink
Jar Application Deployment Timeouts - version
Id String - ApplicationVersion ID. Length must be exactly
36. Changing this property forces recreation of the resource.
- application
Id string - Application Id. Changing this property forces recreation of the resource.
- created
At string - The creation timestamp of this entity in ISO 8601 format, always in UTC.
- created
By string - The creator of this entity.
- deployment
Id string - Deployment ID.
- entry
Class string - The fully qualified name of the entry class to pass during Flink job submission through the entryClass parameter. Length must be between
1and128. Changing this property forces recreation of the resource. - error
Msg string - Error message describing what caused deployment to fail.
- job
Id string - Job ID.
- last
Savepoint string - Job savepoint.
- parallelism number
- Reading of Flink parallel execution documentation is recommended before setting this value to other than 1. Please do not set this value higher than (total number of nodes x numberoftask_slots), or every new job created will fail. Value must be between
1and128. Changing this property forces recreation of the resource. - program
Args string[] - Arguments to pass during Flink job submission through the programArgsList parameter. Changing this property forces recreation of the resource.
- project string
- Project name. Changing this property forces recreation of the resource.
- restart
Enabled boolean - Specifies whether a Flink Job is restarted in case it fails. Changing this property forces recreation of the resource.
- service
Name string - Service name. Changing this property forces recreation of the resource.
- starting
Savepoint string - Job savepoint. Length must be between
1and2048. Changing this property forces recreation of the resource. - status string
- Deployment status. The possible values are
CANCELED,CANCELLING,CANCELLING_REQUESTED,CREATED,DELETE_REQUESTED,DELETING,FAILED,FAILING,FINISHED,INITIALIZING,RECONCILING,RESTARTING,RUNNING,SAVING,SAVING_AND_STOP,SAVING_AND_STOP_REQUESTEDandSUSPENDED. - timeouts
Flink
Jar Application Deployment Timeouts - version
Id string - ApplicationVersion ID. Length must be exactly
36. Changing this property forces recreation of the resource.
- application_
id str - Application Id. Changing this property forces recreation of the resource.
- created_
at str - The creation timestamp of this entity in ISO 8601 format, always in UTC.
- created_
by str - The creator of this entity.
- deployment_
id str - Deployment ID.
- entry_
class str - The fully qualified name of the entry class to pass during Flink job submission through the entryClass parameter. Length must be between
1and128. Changing this property forces recreation of the resource. - error_
msg str - Error message describing what caused deployment to fail.
- job_
id str - Job ID.
- last_
savepoint str - Job savepoint.
- parallelism int
- Reading of Flink parallel execution documentation is recommended before setting this value to other than 1. Please do not set this value higher than (total number of nodes x numberoftask_slots), or every new job created will fail. Value must be between
1and128. Changing this property forces recreation of the resource. - program_
args Sequence[str] - Arguments to pass during Flink job submission through the programArgsList parameter. Changing this property forces recreation of the resource.
- project str
- Project name. Changing this property forces recreation of the resource.
- restart_
enabled bool - Specifies whether a Flink Job is restarted in case it fails. Changing this property forces recreation of the resource.
- service_
name str - Service name. Changing this property forces recreation of the resource.
- starting_
savepoint str - Job savepoint. Length must be between
1and2048. Changing this property forces recreation of the resource. - status str
- Deployment status. The possible values are
CANCELED,CANCELLING,CANCELLING_REQUESTED,CREATED,DELETE_REQUESTED,DELETING,FAILED,FAILING,FINISHED,INITIALIZING,RECONCILING,RESTARTING,RUNNING,SAVING,SAVING_AND_STOP,SAVING_AND_STOP_REQUESTEDandSUSPENDED. - timeouts
Flink
Jar Application Deployment Timeouts Args - version_
id str - ApplicationVersion ID. Length must be exactly
36. Changing this property forces recreation of the resource.
- application
Id String - Application Id. Changing this property forces recreation of the resource.
- created
At String - The creation timestamp of this entity in ISO 8601 format, always in UTC.
- created
By String - The creator of this entity.
- deployment
Id String - Deployment ID.
- entry
Class String - The fully qualified name of the entry class to pass during Flink job submission through the entryClass parameter. Length must be between
1and128. Changing this property forces recreation of the resource. - error
Msg String - Error message describing what caused deployment to fail.
- job
Id String - Job ID.
- last
Savepoint String - Job savepoint.
- parallelism Number
- Reading of Flink parallel execution documentation is recommended before setting this value to other than 1. Please do not set this value higher than (total number of nodes x numberoftask_slots), or every new job created will fail. Value must be between
1and128. Changing this property forces recreation of the resource. - program
Args List<String> - Arguments to pass during Flink job submission through the programArgsList parameter. Changing this property forces recreation of the resource.
- project String
- Project name. Changing this property forces recreation of the resource.
- restart
Enabled Boolean - Specifies whether a Flink Job is restarted in case it fails. Changing this property forces recreation of the resource.
- service
Name String - Service name. Changing this property forces recreation of the resource.
- starting
Savepoint String - Job savepoint. Length must be between
1and2048. Changing this property forces recreation of the resource. - status String
- Deployment status. The possible values are
CANCELED,CANCELLING,CANCELLING_REQUESTED,CREATED,DELETE_REQUESTED,DELETING,FAILED,FAILING,FINISHED,INITIALIZING,RECONCILING,RESTARTING,RUNNING,SAVING,SAVING_AND_STOP,SAVING_AND_STOP_REQUESTEDandSUSPENDED. - timeouts Property Map
- version
Id String - ApplicationVersion ID. Length must be exactly
36. Changing this property forces recreation of the resource.
Supporting Types
FlinkJarApplicationDeploymentTimeouts, FlinkJarApplicationDeploymentTimeoutsArgs
- Create string
- A string that can be parsed as a duration consisting of numbers and unit suffixes, such as "30s" or "2h45m". Valid time units are "s" (seconds), "m" (minutes), "h" (hours).
- Default string
- Timeout for all operations. Deprecated, use operation-specific timeouts instead.
- Delete string
- A string that can be parsed as a duration consisting of numbers and unit suffixes, such as "30s" or "2h45m". Valid time units are "s" (seconds), "m" (minutes), "h" (hours). Setting a timeout for a Delete operation is only applicable if changes are saved into state before the destroy operation occurs.
- Read string
- A string that can be parsed as a duration consisting of numbers and unit suffixes, such as "30s" or "2h45m". Valid time units are "s" (seconds), "m" (minutes), "h" (hours). Read operations occur during any refresh or planning operation when refresh is enabled.
- Update string
- A string that can be parsed as a duration consisting of numbers and unit suffixes, such as "30s" or "2h45m". Valid time units are "s" (seconds), "m" (minutes), "h" (hours).
- Create string
- A string that can be parsed as a duration consisting of numbers and unit suffixes, such as "30s" or "2h45m". Valid time units are "s" (seconds), "m" (minutes), "h" (hours).
- Default string
- Timeout for all operations. Deprecated, use operation-specific timeouts instead.
- Delete string
- A string that can be parsed as a duration consisting of numbers and unit suffixes, such as "30s" or "2h45m". Valid time units are "s" (seconds), "m" (minutes), "h" (hours). Setting a timeout for a Delete operation is only applicable if changes are saved into state before the destroy operation occurs.
- Read string
- A string that can be parsed as a duration consisting of numbers and unit suffixes, such as "30s" or "2h45m". Valid time units are "s" (seconds), "m" (minutes), "h" (hours). Read operations occur during any refresh or planning operation when refresh is enabled.
- Update string
- A string that can be parsed as a duration consisting of numbers and unit suffixes, such as "30s" or "2h45m". Valid time units are "s" (seconds), "m" (minutes), "h" (hours).
- create string
- A string that can be parsed as a duration consisting of numbers and unit suffixes, such as "30s" or "2h45m". Valid time units are "s" (seconds), "m" (minutes), "h" (hours).
- default string
- Timeout for all operations. Deprecated, use operation-specific timeouts instead.
- delete string
- A string that can be parsed as a duration consisting of numbers and unit suffixes, such as "30s" or "2h45m". Valid time units are "s" (seconds), "m" (minutes), "h" (hours). Setting a timeout for a Delete operation is only applicable if changes are saved into state before the destroy operation occurs.
- read string
- A string that can be parsed as a duration consisting of numbers and unit suffixes, such as "30s" or "2h45m". Valid time units are "s" (seconds), "m" (minutes), "h" (hours). Read operations occur during any refresh or planning operation when refresh is enabled.
- update string
- A string that can be parsed as a duration consisting of numbers and unit suffixes, such as "30s" or "2h45m". Valid time units are "s" (seconds), "m" (minutes), "h" (hours).
- create String
- A string that can be parsed as a duration consisting of numbers and unit suffixes, such as "30s" or "2h45m". Valid time units are "s" (seconds), "m" (minutes), "h" (hours).
- default_ String
- Timeout for all operations. Deprecated, use operation-specific timeouts instead.
- delete String
- A string that can be parsed as a duration consisting of numbers and unit suffixes, such as "30s" or "2h45m". Valid time units are "s" (seconds), "m" (minutes), "h" (hours). Setting a timeout for a Delete operation is only applicable if changes are saved into state before the destroy operation occurs.
- read String
- A string that can be parsed as a duration consisting of numbers and unit suffixes, such as "30s" or "2h45m". Valid time units are "s" (seconds), "m" (minutes), "h" (hours). Read operations occur during any refresh or planning operation when refresh is enabled.
- update String
- A string that can be parsed as a duration consisting of numbers and unit suffixes, such as "30s" or "2h45m". Valid time units are "s" (seconds), "m" (minutes), "h" (hours).
- create string
- A string that can be parsed as a duration consisting of numbers and unit suffixes, such as "30s" or "2h45m". Valid time units are "s" (seconds), "m" (minutes), "h" (hours).
- default string
- Timeout for all operations. Deprecated, use operation-specific timeouts instead.
- delete string
- A string that can be parsed as a duration consisting of numbers and unit suffixes, such as "30s" or "2h45m". Valid time units are "s" (seconds), "m" (minutes), "h" (hours). Setting a timeout for a Delete operation is only applicable if changes are saved into state before the destroy operation occurs.
- read string
- A string that can be parsed as a duration consisting of numbers and unit suffixes, such as "30s" or "2h45m". Valid time units are "s" (seconds), "m" (minutes), "h" (hours). Read operations occur during any refresh or planning operation when refresh is enabled.
- update string
- A string that can be parsed as a duration consisting of numbers and unit suffixes, such as "30s" or "2h45m". Valid time units are "s" (seconds), "m" (minutes), "h" (hours).
- create str
- A string that can be parsed as a duration consisting of numbers and unit suffixes, such as "30s" or "2h45m". Valid time units are "s" (seconds), "m" (minutes), "h" (hours).
- default str
- Timeout for all operations. Deprecated, use operation-specific timeouts instead.
- delete str
- A string that can be parsed as a duration consisting of numbers and unit suffixes, such as "30s" or "2h45m". Valid time units are "s" (seconds), "m" (minutes), "h" (hours). Setting a timeout for a Delete operation is only applicable if changes are saved into state before the destroy operation occurs.
- read str
- A string that can be parsed as a duration consisting of numbers and unit suffixes, such as "30s" or "2h45m". Valid time units are "s" (seconds), "m" (minutes), "h" (hours). Read operations occur during any refresh or planning operation when refresh is enabled.
- update str
- A string that can be parsed as a duration consisting of numbers and unit suffixes, such as "30s" or "2h45m". Valid time units are "s" (seconds), "m" (minutes), "h" (hours).
- create String
- A string that can be parsed as a duration consisting of numbers and unit suffixes, such as "30s" or "2h45m". Valid time units are "s" (seconds), "m" (minutes), "h" (hours).
- default String
- Timeout for all operations. Deprecated, use operation-specific timeouts instead.
- delete String
- A string that can be parsed as a duration consisting of numbers and unit suffixes, such as "30s" or "2h45m". Valid time units are "s" (seconds), "m" (minutes), "h" (hours). Setting a timeout for a Delete operation is only applicable if changes are saved into state before the destroy operation occurs.
- read String
- A string that can be parsed as a duration consisting of numbers and unit suffixes, such as "30s" or "2h45m". Valid time units are "s" (seconds), "m" (minutes), "h" (hours). Read operations occur during any refresh or planning operation when refresh is enabled.
- update String
- A string that can be parsed as a duration consisting of numbers and unit suffixes, such as "30s" or "2h45m". Valid time units are "s" (seconds), "m" (minutes), "h" (hours).
Import
$ pulumi import aiven:index/flinkJarApplicationDeployment:FlinkJarApplicationDeployment example PROJECT/SERVICE_NAME/APPLICATION_ID/DEPLOYMENT_ID
To learn more about importing existing cloud resources, see Importing resources.
Package Details
- Repository
- Aiven pulumi/pulumi-aiven
- License
- Apache-2.0
- Notes
- This Pulumi package is based on the
aivenTerraform Provider.
published on Wednesday, Sep 23, 2026 by Pulumi