Skip to content

Commit 8fd8ee8

Browse files
authored
feat(kinesisanalytics-flink): add support for Flink 1.18 (#29554)
### Reason for this change Amazon Kinesis Data Analytics now supports Apache Flink v1.18 ([LINK](https://aws.amazon.com/about-aws/whats-new/2024/03/amazon-managed-service-apache-flink-support-1-18/)) This is also supported in Cloudformation ([LINK](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-kinesisanalyticsv2-application.html#aws-resource-kinesisanalyticsv2-application-properties)) ### Description of changes - Added Flink 1.18 to `Runtime` type - Updated Readme to reference Flink 1.18 ### Checklist - [x] My code adheres to the [CONTRIBUTING GUIDE](https://github.com/aws/aws-cdk/blob/main/CONTRIBUTING.md) and [DESIGN GUIDELINES](https://github.com/aws/aws-cdk/blob/main/docs/DESIGN_GUIDELINES.md) ---- *By submitting this pull request, I confirm that my contribution is made under the terms of the Apache-2.0 license*
1 parent 3f6f88b commit 8fd8ee8

24 files changed

+383
-310
lines changed

packages/@aws-cdk/aws-kinesisanalytics-flink-alpha/README.md

+3-3
Original file line numberDiff line numberDiff line change
@@ -46,7 +46,7 @@ const flinkApp = new flink.Application(this, 'Application', {
4646
},
4747
},
4848
// ...
49-
runtime: flink.Runtime.FLINK_1_15,
49+
runtime: flink.Runtime.FLINK_1_18,
5050
code: flink.ApplicationCode.fromBucket(bucket, 'my-app.jar'),
5151
});
5252
```
@@ -59,7 +59,7 @@ snapshotting, monitoring, and parallelism.
5959
declare const bucket: s3.Bucket;
6060
const flinkApp = new flink.Application(this, 'Application', {
6161
code: flink.ApplicationCode.fromBucket(bucket, 'my-app.jar'),
62-
runtime: flink.Runtime.FLINK_1_15,
62+
runtime: flink.Runtime.FLINK_1_18,
6363
checkpointingEnabled: true, // default is true
6464
checkpointInterval: Duration.seconds(30), // default is 1 minute
6565
minPauseBetweenCheckpoints: Duration.seconds(10), // default is 5 seconds
@@ -80,7 +80,7 @@ declare const bucket: s3.Bucket;
8080
declare const vpc: ec2.Vpc;
8181
const flinkApp = new flink.Application(this, 'Application', {
8282
code: flink.ApplicationCode.fromBucket(bucket, 'my-app.jar'),
83-
runtime: flink.Runtime.FLINK_1_15,
83+
runtime: flink.Runtime.FLINK_1_18,
8484
vpc,
8585
});
8686
```

packages/@aws-cdk/aws-kinesisanalytics-flink-alpha/lib/types.ts

+3
Original file line numberDiff line numberDiff line change
@@ -66,6 +66,9 @@ export class Runtime {
6666
/** Flink Version 1.15 */
6767
public static readonly FLINK_1_15 = Runtime.of('FLINK-1_15');
6868

69+
/** Flink Version 1.18 */
70+
public static readonly FLINK_1_18 = Runtime.of('FLINK-1_18');
71+
6972
/** Create a new Runtime with with an arbitrary Flink version string */
7073
public static of(value: string) {
7174
return new Runtime(value);

packages/@aws-cdk/aws-kinesisanalytics-flink-alpha/test/integ.application-code-from-bucket.lit.js.snapshot/FlinkAppCodeFromBucketTest.assets.json

+3-3
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

packages/@aws-cdk/aws-kinesisanalytics-flink-alpha/test/integ.application-code-from-bucket.lit.js.snapshot/FlinkAppCodeFromBucketTest.template.json

+7-7
Original file line numberDiff line numberDiff line change
@@ -147,13 +147,6 @@
147147
"AppF1B96344": {
148148
"Type": "AWS::KinesisAnalyticsV2::Application",
149149
"Properties": {
150-
"RuntimeEnvironment": "FLINK-1_11",
151-
"ServiceExecutionRole": {
152-
"Fn::GetAtt": [
153-
"AppRole1AF9B530",
154-
"Arn"
155-
]
156-
},
157150
"ApplicationConfiguration": {
158151
"ApplicationCodeConfiguration": {
159152
"CodeContent": {
@@ -181,6 +174,13 @@
181174
"ApplicationSnapshotConfiguration": {
182175
"SnapshotsEnabled": true
183176
}
177+
},
178+
"RuntimeEnvironment": "FLINK-1_18",
179+
"ServiceExecutionRole": {
180+
"Fn::GetAtt": [
181+
"AppRole1AF9B530",
182+
"Arn"
183+
]
184184
}
185185
},
186186
"DependsOn": [

packages/@aws-cdk/aws-kinesisanalytics-flink-alpha/test/integ.application-code-from-bucket.lit.js.snapshot/cdk.out

+1-1
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

packages/@aws-cdk/aws-kinesisanalytics-flink-alpha/test/integ.application-code-from-bucket.lit.js.snapshot/integ.json

+1-1
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

packages/@aws-cdk/aws-kinesisanalytics-flink-alpha/test/integ.application-code-from-bucket.lit.js.snapshot/manifest.json

+17-10
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

packages/@aws-cdk/aws-kinesisanalytics-flink-alpha/test/integ.application-code-from-bucket.lit.js.snapshot/tree.json

+57-33
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

packages/@aws-cdk/aws-kinesisanalytics-flink-alpha/test/integ.application-code-from-bucket.lit.ts

+1-1
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@ const fileKey = asset.s3ObjectKey;
1515
///! show
1616
new flink.Application(stack, 'App', {
1717
code: flink.ApplicationCode.fromBucket(bucket, fileKey),
18-
runtime: flink.Runtime.FLINK_1_11,
18+
runtime: flink.Runtime.FLINK_1_18,
1919
});
2020
///! hide
2121

0 commit comments

Comments
 (0)