class Runtime 🔹

Language	Type name
.NET	Amazon.CDK.AWS.Kinesisanalytics.Flink.Alpha.Runtime
Go	github.com/aws/aws-cdk-go/awscdkkinesisanalyticsflinkalpha/v2#Runtime
Java	software.amazon.awscdk.services.kinesisanalytics.flink.alpha.Runtime
Python	aws_cdk.aws_kinesisanalytics_flink_alpha.Runtime
TypeScript (source)	@aws-cdk/aws-kinesisanalytics-flink-alpha » Runtime

Available Flink runtimes for Kinesis Analytics.

Example

declare const bucket: s3.Bucket;
const flinkApp = new flink.Application(this, 'Application', {
  code: flink.ApplicationCode.fromBucket(bucket, 'my-app.jar'),
  runtime: flink.Runtime.FLINK_1_20,
  checkpointingEnabled: true, // default is true
  checkpointInterval: Duration.seconds(30), // default is 1 minute
  minPauseBetweenCheckpoints: Duration.seconds(10), // default is 5 seconds
  logLevel: flink.LogLevel.ERROR, // default is INFO
  metricsLevel: flink.MetricsLevel.PARALLELISM, // default is APPLICATION
  autoScalingEnabled: false, // default is true
  parallelism: 32, // default is 1
  parallelismPerKpu: 2, // default is 1
  snapshotsEnabled: false, // default is true
  logGroup: new logs.LogGroup(this, 'LogGroup'), // by default, a new LogGroup will be created
});

Properties

Name	Type	Description
value🔹	string	The Cfn string that represents a version of Flink.
static FLINK_1_11🔹	Runtime	Flink Version 1.11.
static FLINK_1_13🔹	Runtime	Flink Version 1.13.
static FLINK_1_15🔹	Runtime	Flink Version 1.15.
static FLINK_1_18🔹	Runtime	Flink Version 1.18.
static FLINK_1_19🔹	Runtime	Flink Version 1.19.
static FLINK_1_20🔹	Runtime	Flink Version 1.20.
static FLINK_1_6🔹	Runtime	Flink Version 1.6.
static FLINK_1_8🔹	Runtime	Flink Version 1.8.
static SQL_1_0🔹	Runtime	SQL Version 1.0.
static ZEPPELIN_FLINK_1_0🔹	Runtime	Zeppelin Flink Version 1.0.
static ZEPPELIN_FLINK_2_0🔹	Runtime	Zeppelin Flink Version 2.0.
static ZEPPELIN_FLINK_3_0🔹	Runtime	Zeppelin Flink Version 3.0.

---

value🔹

Type: string

The Cfn string that represents a version of Flink.

---

static FLINK_1_11🔹

Type: Runtime

Flink Version 1.11.

---

static FLINK_1_13🔹

Type: Runtime

Flink Version 1.13.

---

static FLINK_1_15🔹

Type: Runtime

Flink Version 1.15.

---

static FLINK_1_18🔹

Type: Runtime

Flink Version 1.18.

---

static FLINK_1_19🔹

Type: Runtime

Flink Version 1.19.

---

static FLINK_1_20🔹

Type: Runtime

Flink Version 1.20.

---

static FLINK_1_6🔹

Type: Runtime

Flink Version 1.6.

---

static FLINK_1_8🔹

Type: Runtime

Flink Version 1.8.

---

static SQL_1_0🔹

Type: Runtime

SQL Version 1.0.

---

static ZEPPELIN_FLINK_1_0🔹

Type: Runtime

Zeppelin Flink Version 1.0.

---

static ZEPPELIN_FLINK_2_0🔹

Type: Runtime

Zeppelin Flink Version 2.0.

---

static ZEPPELIN_FLINK_3_0🔹

Type: Runtime

Zeppelin Flink Version 3.0.

Methods

Name	Description
static of(value)🔹	Create a new Runtime with with an arbitrary Flink version string.

---

static of(value)🔹

public static of(value: string): Runtime

Parameters

• value string

Returns

• Runtime

Create a new Runtime with with an arbitrary Flink version string.