feat(kinesisanalytics-flink): support for Flink 1.19 runtime

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

@@ -46,7 +46,7 @@ const flinkApp = new flink.Application(this, 'Application', {
     },
   },
   // ...
-  runtime: flink.Runtime.FLINK_1_18,
+  runtime: flink.Runtime.FLINK_1_19,
   code: flink.ApplicationCode.fromBucket(bucket, 'my-app.jar'),
 });
 ```
@@ -59,7 +59,7 @@ snapshotting, monitoring, and parallelism.
 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_18,
+  runtime: flink.Runtime.FLINK_1_19,
   checkpointingEnabled: true, // default is true
   checkpointInterval: Duration.seconds(30), // default is 1 minute
   minPauseBetweenCheckpoints: Duration.seconds(10), // default is 5 seconds
@@ -80,7 +80,7 @@ declare const bucket: s3.Bucket;
 declare const vpc: ec2.Vpc;
 const flinkApp = new flink.Application(this, 'Application', {
   code: flink.ApplicationCode.fromBucket(bucket, 'my-app.jar'),
-  runtime: flink.Runtime.FLINK_1_18,
+  runtime: flink.Runtime.FLINK_1_19,
   vpc,
 });
 ```

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

@@ -69,6 +69,9 @@ export class Runtime {
   /** Flink Version 1.18 */
   public static readonly FLINK_1_18 = Runtime.of('FLINK-1_18');
 
+ /** Flink Version 1.19 */
+  public static readonly FLINK_1_19 = Runtime.of('FLINK-1_19');
+
   /** Create a new Runtime with with an arbitrary Flink version string */
   public static of(value: string) {
     return new Runtime(value);

packages/@aws-cdk/aws-kinesisanalytics-flink-alpha/test/application.test.ts

@@ -21,21 +21,21 @@ describe('Application', () => {
     stack = new core.Stack();
     bucket = new s3.Bucket(stack, 'CodeBucket');
     requiredProps = {
-      runtime: flink.Runtime.FLINK_1_11,
+      runtime: flink.Runtime.FLINK_1_19,
       code: flink.ApplicationCode.fromBucket(bucket, 'my-app.jar'),
     };
   });
 
   test('default Flink Application', () => {
     new flink.Application(stack, 'FlinkApplication', {
-      runtime: flink.Runtime.FLINK_1_11,
+      runtime: flink.Runtime.FLINK_1_19,
       code: flink.ApplicationCode.fromBucket(bucket, 'my-app.jar'),
       applicationName: 'MyFlinkApplication',
     });
 
     Template.fromStack(stack).hasResourceProperties('AWS::KinesisAnalyticsV2::Application', {
       ApplicationName: 'MyFlinkApplication',
-      RuntimeEnvironment: 'FLINK-1_11',
+      RuntimeEnvironment: 'FLINK-1_19',
       ServiceExecutionRole: {
         'Fn::GetAtt': [
           'FlinkApplicationRole2F7BCBF6',

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

@@ -2,6 +2,7 @@ import * as path from 'path';
 import * as assets from 'aws-cdk-lib/aws-s3-assets';
 import * as core from 'aws-cdk-lib';
 import * as flink from '../lib';
+import * as integ from '@aws-cdk/integ-tests-alpha';
 
 const app = new core.App();
 const stack = new core.Stack(app, 'FlinkAppCodeFromBucketTest');
@@ -15,8 +16,10 @@ const fileKey = asset.s3ObjectKey;
 ///! show
 new flink.Application(stack, 'App', {
   code: flink.ApplicationCode.fromBucket(bucket, fileKey),
-  runtime: flink.Runtime.FLINK_1_18,
+  runtime: flink.Runtime.FLINK_1_19,
 });
 ///! hide
 
-app.synth();
+new integ.IntegTest(app, 'VpcTest', {
+  testCases: [stack],
+});