Skip to content

Commit

Permalink
chore(aws-kinesisanalytics-flink): add support to Flink 1.13 (aws#17019)
Browse files Browse the repository at this point in the history
Add support to Flink 1.13 in construct `@aws-cdk/aws-kinesisanalytics-flink » Application`

This fixes aws#16985

----

*By submitting this pull request, I confirm that my contribution is made under the terms of the Apache-2.0 license*
  • Loading branch information
mattiamatrix authored and TikiTDO committed Feb 21, 2022
1 parent b664889 commit 0df5f7b
Show file tree
Hide file tree
Showing 2 changed files with 5 additions and 2 deletions.
2 changes: 1 addition & 1 deletion packages/@aws-cdk/aws-kinesisanalytics-flink/README.md
Original file line number Diff line number Diff line change
Expand Up @@ -59,7 +59,7 @@ import * as logs from '@aws-cdk/aws-logs';

const flinkApp = new flink.Application(this, 'Application', {
code: flink.ApplicationCode.fromBucket(bucket, 'my-app.jar'),
runtime: file.Runtime.FLINK_1_11,
runtime: file.Runtime.FLINK_1_13,
checkpointingEnabled: true, // default is true
checkpointInterval: cdk.Duration.seconds(30), // default is 1 minute
minPauseBetweenCheckpoints: cdk.Duration.seconds(10), // default is 5 seconds
Expand Down
5 changes: 4 additions & 1 deletion packages/@aws-cdk/aws-kinesisanalytics-flink/lib/types.ts
Original file line number Diff line number Diff line change
Expand Up @@ -37,7 +37,7 @@ export enum MetricsLevel {
* configuration.
*/
export interface PropertyGroups {
readonly [propertyId: string]: {[mapKey: string]: string};
readonly [propertyId: string]: { [mapKey: string]: string };
}

/**
Expand All @@ -53,6 +53,9 @@ export class Runtime {
/** Flink Version 1.11 */
public static readonly FLINK_1_11 = Runtime.of('FLINK-1_11');

/** Flink Version 1.13 */
public static readonly FLINK_1_13 = Runtime.of('FLINK-1_13');

/** Create a new Runtime with with an arbitrary Flink version string */
public static of(value: string) {
return new Runtime(value);
Expand Down

0 comments on commit 0df5f7b

Please sign in to comment.