aiven.FlinkJarApplication
Explore with Pulumi AI
Creates and manages an Aiven for Apache Flink® jar application.
This resource is in the beta stage and may change without notice. Set
the PROVIDER_AIVEN_ENABLE_BETA
environment variable to use the resource.
Example Usage
import * as pulumi from "@pulumi/pulumi";
import * as aiven from "@pulumi/aiven";
const example = new aiven.Flink("example", {
project: exampleAivenProject.project,
serviceName: "example-flink-service",
cloudName: "google-europe-west1",
plan: "business-4",
maintenanceWindowDow: "monday",
maintenanceWindowTime: "04:00:00",
flinkUserConfig: {
customCode: true,
},
});
const exampleFlinkJarApplication = new aiven.FlinkJarApplication("example", {
project: example.project,
serviceName: example.serviceName,
name: "example-app-jar",
});
import pulumi
import pulumi_aiven as aiven
example = aiven.Flink("example",
project=example_aiven_project["project"],
service_name="example-flink-service",
cloud_name="google-europe-west1",
plan="business-4",
maintenance_window_dow="monday",
maintenance_window_time="04:00:00",
flink_user_config={
"custom_code": True,
})
example_flink_jar_application = aiven.FlinkJarApplication("example",
project=example.project,
service_name=example.service_name,
name="example-app-jar")
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 {
example, err := aiven.NewFlink(ctx, "example", &aiven.FlinkArgs{
Project: pulumi.Any(exampleAivenProject.Project),
ServiceName: pulumi.String("example-flink-service"),
CloudName: pulumi.String("google-europe-west1"),
Plan: pulumi.String("business-4"),
MaintenanceWindowDow: pulumi.String("monday"),
MaintenanceWindowTime: pulumi.String("04:00:00"),
FlinkUserConfig: &aiven.FlinkFlinkUserConfigArgs{
CustomCode: pulumi.Bool(true),
},
})
if err != nil {
return err
}
_, err = aiven.NewFlinkJarApplication(ctx, "example", &aiven.FlinkJarApplicationArgs{
Project: example.Project,
ServiceName: example.ServiceName,
Name: pulumi.String("example-app-jar"),
})
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.Flink("example", new()
{
Project = exampleAivenProject.Project,
ServiceName = "example-flink-service",
CloudName = "google-europe-west1",
Plan = "business-4",
MaintenanceWindowDow = "monday",
MaintenanceWindowTime = "04:00:00",
FlinkUserConfig = new Aiven.Inputs.FlinkFlinkUserConfigArgs
{
CustomCode = true,
},
});
var exampleFlinkJarApplication = new Aiven.FlinkJarApplication("example", new()
{
Project = example.Project,
ServiceName = example.ServiceName,
Name = "example-app-jar",
});
});
package generated_program;
import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.aiven.Flink;
import com.pulumi.aiven.FlinkArgs;
import com.pulumi.aiven.inputs.FlinkFlinkUserConfigArgs;
import com.pulumi.aiven.FlinkJarApplication;
import com.pulumi.aiven.FlinkJarApplicationArgs;
import java.util.List;
import java.util.ArrayList;
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 Flink("example", FlinkArgs.builder()
.project(exampleAivenProject.project())
.serviceName("example-flink-service")
.cloudName("google-europe-west1")
.plan("business-4")
.maintenanceWindowDow("monday")
.maintenanceWindowTime("04:00:00")
.flinkUserConfig(FlinkFlinkUserConfigArgs.builder()
.customCode(true)
.build())
.build());
var exampleFlinkJarApplication = new FlinkJarApplication("exampleFlinkJarApplication", FlinkJarApplicationArgs.builder()
.project(example.project())
.serviceName(example.serviceName())
.name("example-app-jar")
.build());
}
}
resources:
example:
type: aiven:Flink
properties:
project: ${exampleAivenProject.project}
serviceName: example-flink-service
cloudName: google-europe-west1
plan: business-4
maintenanceWindowDow: monday
maintenanceWindowTime: 04:00:00
flinkUserConfig:
customCode: true
exampleFlinkJarApplication:
type: aiven:FlinkJarApplication
name: example
properties:
project: ${example.project}
serviceName: ${example.serviceName}
name: example-app-jar
Create FlinkJarApplication Resource
Resources are created with functions called constructors. To learn more about declaring and configuring resources, see Resources.
Constructor syntax
new FlinkJarApplication(name: string, args: FlinkJarApplicationArgs, opts?: CustomResourceOptions);
@overload
def FlinkJarApplication(resource_name: str,
args: FlinkJarApplicationArgs,
opts: Optional[ResourceOptions] = None)
@overload
def FlinkJarApplication(resource_name: str,
opts: Optional[ResourceOptions] = None,
project: Optional[str] = None,
service_name: Optional[str] = None,
name: Optional[str] = None)
func NewFlinkJarApplication(ctx *Context, name string, args FlinkJarApplicationArgs, opts ...ResourceOption) (*FlinkJarApplication, error)
public FlinkJarApplication(string name, FlinkJarApplicationArgs args, CustomResourceOptions? opts = null)
public FlinkJarApplication(String name, FlinkJarApplicationArgs args)
public FlinkJarApplication(String name, FlinkJarApplicationArgs args, CustomResourceOptions options)
type: aiven:FlinkJarApplication
properties: # The arguments to resource properties.
options: # Bag of options to control resource's behavior.
Parameters
- name string
- The unique name of the resource.
- args FlinkJarApplicationArgs
- 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 FlinkJarApplicationArgs
- 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 FlinkJarApplicationArgs
- The arguments to resource properties.
- opts ResourceOption
- Bag of options to control resource's behavior.
- name string
- The unique name of the resource.
- args FlinkJarApplicationArgs
- The arguments to resource properties.
- opts CustomResourceOptions
- Bag of options to control resource's behavior.
- name String
- The unique name of the resource.
- args FlinkJarApplicationArgs
- 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 flinkJarApplicationResource = new Aiven.FlinkJarApplication("flinkJarApplicationResource", new()
{
Project = "string",
ServiceName = "string",
Name = "string",
});
example, err := aiven.NewFlinkJarApplication(ctx, "flinkJarApplicationResource", &aiven.FlinkJarApplicationArgs{
Project: pulumi.String("string"),
ServiceName: pulumi.String("string"),
Name: pulumi.String("string"),
})
var flinkJarApplicationResource = new FlinkJarApplication("flinkJarApplicationResource", FlinkJarApplicationArgs.builder()
.project("string")
.serviceName("string")
.name("string")
.build());
flink_jar_application_resource = aiven.FlinkJarApplication("flinkJarApplicationResource",
project="string",
service_name="string",
name="string")
const flinkJarApplicationResource = new aiven.FlinkJarApplication("flinkJarApplicationResource", {
project: "string",
serviceName: "string",
name: "string",
});
type: aiven:FlinkJarApplication
properties:
name: string
project: string
serviceName: string
FlinkJarApplication 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 FlinkJarApplication resource accepts the following input properties:
- 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.
- Name string
- Application name. Maximum length:
128
.
- 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.
- Name string
- Application name. Maximum length:
128
.
- 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.
- name String
- Application name. Maximum length:
128
.
- 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.
- name string
- Application name. Maximum length:
128
.
- 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.
- name str
- Application name. Maximum length:
128
.
- 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.
- name String
- Application name. Maximum length:
128
.
Outputs
All input properties are implicitly available as output properties. Additionally, the FlinkJarApplication resource produces the following output properties:
- Application
Id string - Application ID.
- Application
Versions List<FlinkJar Application Application Version> - JarApplicationVersions.
- Created
At string - The creation timestamp of this entity in ISO 8601 format, always in UTC.
- Created
By string - The creator of this entity.
- Current
Deployments List<FlinkJar Application Current Deployment> - Flink JarApplicationDeployment.
- Id string
- The provider-assigned unique ID for this managed resource.
- Updated
At string - The update timestamp of this entity in ISO 8601 format, always in UTC.
- Updated
By string - The latest updater of this entity.
- Application
Id string - Application ID.
- Application
Versions []FlinkJar Application Application Version - JarApplicationVersions.
- Created
At string - The creation timestamp of this entity in ISO 8601 format, always in UTC.
- Created
By string - The creator of this entity.
- Current
Deployments []FlinkJar Application Current Deployment - Flink JarApplicationDeployment.
- Id string
- The provider-assigned unique ID for this managed resource.
- Updated
At string - The update timestamp of this entity in ISO 8601 format, always in UTC.
- Updated
By string - The latest updater of this entity.
- application
Id String - Application ID.
- application
Versions List<FlinkJar Application Application Version> - JarApplicationVersions.
- created
At String - The creation timestamp of this entity in ISO 8601 format, always in UTC.
- created
By String - The creator of this entity.
- current
Deployments List<FlinkJar Application Current Deployment> - Flink JarApplicationDeployment.
- id String
- The provider-assigned unique ID for this managed resource.
- updated
At String - The update timestamp of this entity in ISO 8601 format, always in UTC.
- updated
By String - The latest updater of this entity.
- application
Id string - Application ID.
- application
Versions FlinkJar Application Application Version[] - JarApplicationVersions.
- created
At string - The creation timestamp of this entity in ISO 8601 format, always in UTC.
- created
By string - The creator of this entity.
- current
Deployments FlinkJar Application Current Deployment[] - Flink JarApplicationDeployment.
- id string
- The provider-assigned unique ID for this managed resource.
- updated
At string - The update timestamp of this entity in ISO 8601 format, always in UTC.
- updated
By string - The latest updater of this entity.
- application_
id str - Application ID.
- application_
versions Sequence[FlinkJar Application Application Version] - JarApplicationVersions.
- created_
at str - The creation timestamp of this entity in ISO 8601 format, always in UTC.
- created_
by str - The creator of this entity.
- current_
deployments Sequence[FlinkJar Application Current Deployment] - Flink JarApplicationDeployment.
- id str
- The provider-assigned unique ID for this managed resource.
- updated_
at str - The update timestamp of this entity in ISO 8601 format, always in UTC.
- updated_
by str - The latest updater of this entity.
- application
Id String - Application ID.
- application
Versions List<Property Map> - JarApplicationVersions.
- created
At String - The creation timestamp of this entity in ISO 8601 format, always in UTC.
- created
By String - The creator of this entity.
- current
Deployments List<Property Map> - Flink JarApplicationDeployment.
- id String
- The provider-assigned unique ID for this managed resource.
- updated
At String - The update timestamp of this entity in ISO 8601 format, always in UTC.
- updated
By String - The latest updater of this entity.
Look up Existing FlinkJarApplication Resource
Get an existing FlinkJarApplication 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?: FlinkJarApplicationState, opts?: CustomResourceOptions): FlinkJarApplication
@staticmethod
def get(resource_name: str,
id: str,
opts: Optional[ResourceOptions] = None,
application_id: Optional[str] = None,
application_versions: Optional[Sequence[FlinkJarApplicationApplicationVersionArgs]] = None,
created_at: Optional[str] = None,
created_by: Optional[str] = None,
current_deployments: Optional[Sequence[FlinkJarApplicationCurrentDeploymentArgs]] = None,
name: Optional[str] = None,
project: Optional[str] = None,
service_name: Optional[str] = None,
updated_at: Optional[str] = None,
updated_by: Optional[str] = None) -> FlinkJarApplication
func GetFlinkJarApplication(ctx *Context, name string, id IDInput, state *FlinkJarApplicationState, opts ...ResourceOption) (*FlinkJarApplication, error)
public static FlinkJarApplication Get(string name, Input<string> id, FlinkJarApplicationState? state, CustomResourceOptions? opts = null)
public static FlinkJarApplication get(String name, Output<String> id, FlinkJarApplicationState state, CustomResourceOptions options)
resources: _: type: aiven:FlinkJarApplication get: 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.
- Application
Versions List<FlinkJar Application Application Version> - JarApplicationVersions.
- Created
At string - The creation timestamp of this entity in ISO 8601 format, always in UTC.
- Created
By string - The creator of this entity.
- Current
Deployments List<FlinkJar Application Current Deployment> - Flink JarApplicationDeployment.
- Name string
- Application name. Maximum length:
128
. - 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.
- Updated
At string - The update timestamp of this entity in ISO 8601 format, always in UTC.
- Updated
By string - The latest updater of this entity.
- Application
Id string - Application ID.
- Application
Versions []FlinkJar Application Application Version Args - JarApplicationVersions.
- Created
At string - The creation timestamp of this entity in ISO 8601 format, always in UTC.
- Created
By string - The creator of this entity.
- Current
Deployments []FlinkJar Application Current Deployment Args - Flink JarApplicationDeployment.
- Name string
- Application name. Maximum length:
128
. - 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.
- Updated
At string - The update timestamp of this entity in ISO 8601 format, always in UTC.
- Updated
By string - The latest updater of this entity.
- application
Id String - Application ID.
- application
Versions List<FlinkJar Application Application Version> - JarApplicationVersions.
- created
At String - The creation timestamp of this entity in ISO 8601 format, always in UTC.
- created
By String - The creator of this entity.
- current
Deployments List<FlinkJar Application Current Deployment> - Flink JarApplicationDeployment.
- name String
- Application name. Maximum length:
128
. - 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.
- updated
At String - The update timestamp of this entity in ISO 8601 format, always in UTC.
- updated
By String - The latest updater of this entity.
- application
Id string - Application ID.
- application
Versions FlinkJar Application Application Version[] - JarApplicationVersions.
- created
At string - The creation timestamp of this entity in ISO 8601 format, always in UTC.
- created
By string - The creator of this entity.
- current
Deployments FlinkJar Application Current Deployment[] - Flink JarApplicationDeployment.
- name string
- Application name. Maximum length:
128
. - 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.
- updated
At string - The update timestamp of this entity in ISO 8601 format, always in UTC.
- updated
By string - The latest updater of this entity.
- application_
id str - Application ID.
- application_
versions Sequence[FlinkJar Application Application Version Args] - JarApplicationVersions.
- created_
at str - The creation timestamp of this entity in ISO 8601 format, always in UTC.
- created_
by str - The creator of this entity.
- current_
deployments Sequence[FlinkJar Application Current Deployment Args] - Flink JarApplicationDeployment.
- name str
- Application name. Maximum length:
128
. - 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.
- updated_
at str - The update timestamp of this entity in ISO 8601 format, always in UTC.
- updated_
by str - The latest updater of this entity.
- application
Id String - Application ID.
- application
Versions List<Property Map> - JarApplicationVersions.
- created
At String - The creation timestamp of this entity in ISO 8601 format, always in UTC.
- created
By String - The creator of this entity.
- current
Deployments List<Property Map> - Flink JarApplicationDeployment.
- name String
- Application name. Maximum length:
128
. - 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.
- updated
At String - The update timestamp of this entity in ISO 8601 format, always in UTC.
- updated
By String - The latest updater of this entity.
Supporting Types
FlinkJarApplicationApplicationVersion, FlinkJarApplicationApplicationVersionArgs
- created_
at str - The creation timestamp of this entity in ISO 8601 format, always in UTC.
- created_
by str - The creator of this entity.
- file_
infos Sequence[FlinkJar Application Application Version File Info] - Flink JarApplicationVersion FileInfo.
- id str
- ApplicationVersion ID.
- version int
- Version number.
FlinkJarApplicationApplicationVersionFileInfo, FlinkJarApplicationApplicationVersionFileInfoArgs
- File
Sha256 string - sha256 of the file if known.
- File
Size int - The size of the file in bytes.
- File
Status string - Indicates whether the uploaded .jar file has been verified by the system and deployment ready. The possible values are
INITIAL
,READY
andFAILED
. - Url string
- The pre-signed url of the bucket where the .jar file is uploaded. Becomes null when the JarApplicationVersion is ready or failed.
- Verify
Error intCode - In the case file_status is FAILED, the error code of the failure. The possible values are
1
,2
and3
. - Verify
Error stringMessage - In the case file_status is FAILED, may contain details about the failure.
- File
Sha256 string - sha256 of the file if known.
- File
Size int - The size of the file in bytes.
- File
Status string - Indicates whether the uploaded .jar file has been verified by the system and deployment ready. The possible values are
INITIAL
,READY
andFAILED
. - Url string
- The pre-signed url of the bucket where the .jar file is uploaded. Becomes null when the JarApplicationVersion is ready or failed.
- Verify
Error intCode - In the case file_status is FAILED, the error code of the failure. The possible values are
1
,2
and3
. - Verify
Error stringMessage - In the case file_status is FAILED, may contain details about the failure.
- file
Sha256 String - sha256 of the file if known.
- file
Size Integer - The size of the file in bytes.
- file
Status String - Indicates whether the uploaded .jar file has been verified by the system and deployment ready. The possible values are
INITIAL
,READY
andFAILED
. - url String
- The pre-signed url of the bucket where the .jar file is uploaded. Becomes null when the JarApplicationVersion is ready or failed.
- verify
Error IntegerCode - In the case file_status is FAILED, the error code of the failure. The possible values are
1
,2
and3
. - verify
Error StringMessage - In the case file_status is FAILED, may contain details about the failure.
- file
Sha256 string - sha256 of the file if known.
- file
Size number - The size of the file in bytes.
- file
Status string - Indicates whether the uploaded .jar file has been verified by the system and deployment ready. The possible values are
INITIAL
,READY
andFAILED
. - url string
- The pre-signed url of the bucket where the .jar file is uploaded. Becomes null when the JarApplicationVersion is ready or failed.
- verify
Error numberCode - In the case file_status is FAILED, the error code of the failure. The possible values are
1
,2
and3
. - verify
Error stringMessage - In the case file_status is FAILED, may contain details about the failure.
- file_
sha256 str - sha256 of the file if known.
- file_
size int - The size of the file in bytes.
- file_
status str - Indicates whether the uploaded .jar file has been verified by the system and deployment ready. The possible values are
INITIAL
,READY
andFAILED
. - url str
- The pre-signed url of the bucket where the .jar file is uploaded. Becomes null when the JarApplicationVersion is ready or failed.
- verify_
error_ intcode - In the case file_status is FAILED, the error code of the failure. The possible values are
1
,2
and3
. - verify_
error_ strmessage - In the case file_status is FAILED, may contain details about the failure.
- file
Sha256 String - sha256 of the file if known.
- file
Size Number - The size of the file in bytes.
- file
Status String - Indicates whether the uploaded .jar file has been verified by the system and deployment ready. The possible values are
INITIAL
,READY
andFAILED
. - url String
- The pre-signed url of the bucket where the .jar file is uploaded. Becomes null when the JarApplicationVersion is ready or failed.
- verify
Error NumberCode - In the case file_status is FAILED, the error code of the failure. The possible values are
1
,2
and3
. - verify
Error StringMessage - In the case file_status is FAILED, may contain details about the failure.
FlinkJarApplicationCurrentDeployment, FlinkJarApplicationCurrentDeploymentArgs
- Created
At string - The creation timestamp of this entity in ISO 8601 format, always in UTC.
- Created
By string - The creator of this entity.
- Entry
Class string - The fully qualified name of the entry class to pass during Flink job submission through the entryClass parameter.
- Error
Msg string - Error message describing what caused deployment to fail.
- Id string
- Deployment ID.
- 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 number_of_task_slots), or every new job created will fail.
- Program
Args List<string> - Arguments to pass during Flink job submission through the programArgsList parameter.
- Starting
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_REQUESTED
andSUSPENDED
. - Version
Id string - ApplicationVersion ID.
- Created
At string - The creation timestamp of this entity in ISO 8601 format, always in UTC.
- Created
By string - The creator of this entity.
- Entry
Class string - The fully qualified name of the entry class to pass during Flink job submission through the entryClass parameter.
- Error
Msg string - Error message describing what caused deployment to fail.
- Id string
- Deployment ID.
- 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 number_of_task_slots), or every new job created will fail.
- Program
Args []string - Arguments to pass during Flink job submission through the programArgsList parameter.
- Starting
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_REQUESTED
andSUSPENDED
. - Version
Id string - ApplicationVersion ID.
- created
At String - The creation timestamp of this entity in ISO 8601 format, always in UTC.
- created
By String - The creator of this entity.
- entry
Class String - The fully qualified name of the entry class to pass during Flink job submission through the entryClass parameter.
- error
Msg String - Error message describing what caused deployment to fail.
- id String
- Deployment ID.
- 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 number_of_task_slots), or every new job created will fail.
- program
Args List<String> - Arguments to pass during Flink job submission through the programArgsList parameter.
- starting
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_REQUESTED
andSUSPENDED
. - version
Id String - ApplicationVersion ID.
- created
At string - The creation timestamp of this entity in ISO 8601 format, always in UTC.
- created
By string - The creator of this entity.
- entry
Class string - The fully qualified name of the entry class to pass during Flink job submission through the entryClass parameter.
- error
Msg string - Error message describing what caused deployment to fail.
- id string
- Deployment ID.
- 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 number_of_task_slots), or every new job created will fail.
- program
Args string[] - Arguments to pass during Flink job submission through the programArgsList parameter.
- starting
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_REQUESTED
andSUSPENDED
. - version
Id string - ApplicationVersion ID.
- created_
at str - The creation timestamp of this entity in ISO 8601 format, always in UTC.
- created_
by str - The creator of this entity.
- entry_
class str - The fully qualified name of the entry class to pass during Flink job submission through the entryClass parameter.
- error_
msg str - Error message describing what caused deployment to fail.
- id str
- Deployment ID.
- 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 number_of_task_slots), or every new job created will fail.
- program_
args Sequence[str] - Arguments to pass during Flink job submission through the programArgsList parameter.
- starting_
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_REQUESTED
andSUSPENDED
. - version_
id str - ApplicationVersion ID.
- created
At String - The creation timestamp of this entity in ISO 8601 format, always in UTC.
- created
By String - The creator of this entity.
- entry
Class String - The fully qualified name of the entry class to pass during Flink job submission through the entryClass parameter.
- error
Msg String - Error message describing what caused deployment to fail.
- id String
- Deployment ID.
- 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 number_of_task_slots), or every new job created will fail.
- program
Args List<String> - Arguments to pass during Flink job submission through the programArgsList parameter.
- starting
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_REQUESTED
andSUSPENDED
. - version
Id String - ApplicationVersion ID.
Import
$ pulumi import aiven:index/flinkJarApplication:FlinkJarApplication example PROJECT/SERVICE_NAME/APPLICATION_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
aiven
Terraform Provider.