Skip to content

Commit 2a5d41e

Browse files
author
awstools
committed
feat(client-kinesis-analytics-v2): Support for Flink 1.19 in Managed Service for Apache Flink
1 parent 988b75a commit 2a5d41e

10 files changed

+32
-25
lines changed

‎clients/client-kinesis-analytics-v2/src/commands/CreateApplicationCommand.ts

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -44,7 +44,7 @@ export interface CreateApplicationCommandOutput extends CreateApplicationRespons
4444
* const input = { // CreateApplicationRequest
4545
* ApplicationName: "STRING_VALUE", // required
4646
* ApplicationDescription: "STRING_VALUE",
47-
* RuntimeEnvironment: "SQL-1_0" || "FLINK-1_6" || "FLINK-1_8" || "ZEPPELIN-FLINK-1_0" || "FLINK-1_11" || "FLINK-1_13" || "ZEPPELIN-FLINK-2_0" || "FLINK-1_15" || "ZEPPELIN-FLINK-3_0" || "FLINK-1_18", // required
47+
* RuntimeEnvironment: "SQL-1_0" || "FLINK-1_6" || "FLINK-1_8" || "ZEPPELIN-FLINK-1_0" || "FLINK-1_11" || "FLINK-1_13" || "ZEPPELIN-FLINK-2_0" || "FLINK-1_15" || "ZEPPELIN-FLINK-3_0" || "FLINK-1_18" || "FLINK-1_19", // required
4848
* ServiceExecutionRole: "STRING_VALUE", // required
4949
* ApplicationConfiguration: { // ApplicationConfiguration
5050
* SqlApplicationConfiguration: { // SqlApplicationConfiguration
@@ -247,7 +247,7 @@ export interface CreateApplicationCommandOutput extends CreateApplicationRespons
247247
* // ApplicationARN: "STRING_VALUE", // required
248248
* // ApplicationDescription: "STRING_VALUE",
249249
* // ApplicationName: "STRING_VALUE", // required
250-
* // RuntimeEnvironment: "SQL-1_0" || "FLINK-1_6" || "FLINK-1_8" || "ZEPPELIN-FLINK-1_0" || "FLINK-1_11" || "FLINK-1_13" || "ZEPPELIN-FLINK-2_0" || "FLINK-1_15" || "ZEPPELIN-FLINK-3_0" || "FLINK-1_18", // required
250+
* // RuntimeEnvironment: "SQL-1_0" || "FLINK-1_6" || "FLINK-1_8" || "ZEPPELIN-FLINK-1_0" || "FLINK-1_11" || "FLINK-1_13" || "ZEPPELIN-FLINK-2_0" || "FLINK-1_15" || "ZEPPELIN-FLINK-3_0" || "FLINK-1_18" || "FLINK-1_19", // required
251251
* // ServiceExecutionRole: "STRING_VALUE",
252252
* // ApplicationStatus: "DELETING" || "STARTING" || "STOPPING" || "READY" || "RUNNING" || "UPDATING" || "AUTOSCALING" || "FORCE_STOPPING" || "ROLLING_BACK" || "MAINTENANCE" || "ROLLED_BACK", // required
253253
* // ApplicationVersionId: Number("long"), // required

‎clients/client-kinesis-analytics-v2/src/commands/DescribeApplicationCommand.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -52,7 +52,7 @@ export interface DescribeApplicationCommandOutput extends DescribeApplicationRes
5252
* // ApplicationARN: "STRING_VALUE", // required
5353
* // ApplicationDescription: "STRING_VALUE",
5454
* // ApplicationName: "STRING_VALUE", // required
55-
* // RuntimeEnvironment: "SQL-1_0" || "FLINK-1_6" || "FLINK-1_8" || "ZEPPELIN-FLINK-1_0" || "FLINK-1_11" || "FLINK-1_13" || "ZEPPELIN-FLINK-2_0" || "FLINK-1_15" || "ZEPPELIN-FLINK-3_0" || "FLINK-1_18", // required
55+
* // RuntimeEnvironment: "SQL-1_0" || "FLINK-1_6" || "FLINK-1_8" || "ZEPPELIN-FLINK-1_0" || "FLINK-1_11" || "FLINK-1_13" || "ZEPPELIN-FLINK-2_0" || "FLINK-1_15" || "ZEPPELIN-FLINK-3_0" || "FLINK-1_18" || "FLINK-1_19", // required
5656
* // ServiceExecutionRole: "STRING_VALUE",
5757
* // ApplicationStatus: "DELETING" || "STARTING" || "STOPPING" || "READY" || "RUNNING" || "UPDATING" || "AUTOSCALING" || "FORCE_STOPPING" || "ROLLING_BACK" || "MAINTENANCE" || "ROLLED_BACK", // required
5858
* // ApplicationVersionId: Number("long"), // required

‎clients/client-kinesis-analytics-v2/src/commands/DescribeApplicationSnapshotCommand.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -53,7 +53,7 @@ export interface DescribeApplicationSnapshotCommandOutput
5353
* // SnapshotStatus: "CREATING" || "READY" || "DELETING" || "FAILED", // required
5454
* // ApplicationVersionId: Number("long"), // required
5555
* // SnapshotCreationTimestamp: new Date("TIMESTAMP"),
56-
* // RuntimeEnvironment: "SQL-1_0" || "FLINK-1_6" || "FLINK-1_8" || "ZEPPELIN-FLINK-1_0" || "FLINK-1_11" || "FLINK-1_13" || "ZEPPELIN-FLINK-2_0" || "FLINK-1_15" || "ZEPPELIN-FLINK-3_0" || "FLINK-1_18",
56+
* // RuntimeEnvironment: "SQL-1_0" || "FLINK-1_6" || "FLINK-1_8" || "ZEPPELIN-FLINK-1_0" || "FLINK-1_11" || "FLINK-1_13" || "ZEPPELIN-FLINK-2_0" || "FLINK-1_15" || "ZEPPELIN-FLINK-3_0" || "FLINK-1_18" || "FLINK-1_19",
5757
* // },
5858
* // };
5959
*

‎clients/client-kinesis-analytics-v2/src/commands/DescribeApplicationVersionCommand.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -53,7 +53,7 @@ export interface DescribeApplicationVersionCommandOutput extends DescribeApplica
5353
* // ApplicationARN: "STRING_VALUE", // required
5454
* // ApplicationDescription: "STRING_VALUE",
5555
* // ApplicationName: "STRING_VALUE", // required
56-
* // RuntimeEnvironment: "SQL-1_0" || "FLINK-1_6" || "FLINK-1_8" || "ZEPPELIN-FLINK-1_0" || "FLINK-1_11" || "FLINK-1_13" || "ZEPPELIN-FLINK-2_0" || "FLINK-1_15" || "ZEPPELIN-FLINK-3_0" || "FLINK-1_18", // required
56+
* // RuntimeEnvironment: "SQL-1_0" || "FLINK-1_6" || "FLINK-1_8" || "ZEPPELIN-FLINK-1_0" || "FLINK-1_11" || "FLINK-1_13" || "ZEPPELIN-FLINK-2_0" || "FLINK-1_15" || "ZEPPELIN-FLINK-3_0" || "FLINK-1_18" || "FLINK-1_19", // required
5757
* // ServiceExecutionRole: "STRING_VALUE",
5858
* // ApplicationStatus: "DELETING" || "STARTING" || "STOPPING" || "READY" || "RUNNING" || "UPDATING" || "AUTOSCALING" || "FORCE_STOPPING" || "ROLLING_BACK" || "MAINTENANCE" || "ROLLED_BACK", // required
5959
* // ApplicationVersionId: Number("long"), // required

‎clients/client-kinesis-analytics-v2/src/commands/ListApplicationSnapshotsCommand.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -53,7 +53,7 @@ export interface ListApplicationSnapshotsCommandOutput extends ListApplicationSn
5353
* // SnapshotStatus: "CREATING" || "READY" || "DELETING" || "FAILED", // required
5454
* // ApplicationVersionId: Number("long"), // required
5555
* // SnapshotCreationTimestamp: new Date("TIMESTAMP"),
56-
* // RuntimeEnvironment: "SQL-1_0" || "FLINK-1_6" || "FLINK-1_8" || "ZEPPELIN-FLINK-1_0" || "FLINK-1_11" || "FLINK-1_13" || "ZEPPELIN-FLINK-2_0" || "FLINK-1_15" || "ZEPPELIN-FLINK-3_0" || "FLINK-1_18",
56+
* // RuntimeEnvironment: "SQL-1_0" || "FLINK-1_6" || "FLINK-1_8" || "ZEPPELIN-FLINK-1_0" || "FLINK-1_11" || "FLINK-1_13" || "ZEPPELIN-FLINK-2_0" || "FLINK-1_15" || "ZEPPELIN-FLINK-3_0" || "FLINK-1_18" || "FLINK-1_19",
5757
* // },
5858
* // ],
5959
* // NextToken: "STRING_VALUE",

‎clients/client-kinesis-analytics-v2/src/commands/ListApplicationsCommand.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -56,7 +56,7 @@ export interface ListApplicationsCommandOutput extends ListApplicationsResponse,
5656
* // ApplicationARN: "STRING_VALUE", // required
5757
* // ApplicationStatus: "DELETING" || "STARTING" || "STOPPING" || "READY" || "RUNNING" || "UPDATING" || "AUTOSCALING" || "FORCE_STOPPING" || "ROLLING_BACK" || "MAINTENANCE" || "ROLLED_BACK", // required
5858
* // ApplicationVersionId: Number("long"), // required
59-
* // RuntimeEnvironment: "SQL-1_0" || "FLINK-1_6" || "FLINK-1_8" || "ZEPPELIN-FLINK-1_0" || "FLINK-1_11" || "FLINK-1_13" || "ZEPPELIN-FLINK-2_0" || "FLINK-1_15" || "ZEPPELIN-FLINK-3_0" || "FLINK-1_18", // required
59+
* // RuntimeEnvironment: "SQL-1_0" || "FLINK-1_6" || "FLINK-1_8" || "ZEPPELIN-FLINK-1_0" || "FLINK-1_11" || "FLINK-1_13" || "ZEPPELIN-FLINK-2_0" || "FLINK-1_15" || "ZEPPELIN-FLINK-3_0" || "FLINK-1_18" || "FLINK-1_19", // required
6060
* // ApplicationMode: "STREAMING" || "INTERACTIVE",
6161
* // },
6262
* // ],

‎clients/client-kinesis-analytics-v2/src/commands/RollbackApplicationCommand.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -55,7 +55,7 @@ export interface RollbackApplicationCommandOutput extends RollbackApplicationRes
5555
* // ApplicationARN: "STRING_VALUE", // required
5656
* // ApplicationDescription: "STRING_VALUE",
5757
* // ApplicationName: "STRING_VALUE", // required
58-
* // RuntimeEnvironment: "SQL-1_0" || "FLINK-1_6" || "FLINK-1_8" || "ZEPPELIN-FLINK-1_0" || "FLINK-1_11" || "FLINK-1_13" || "ZEPPELIN-FLINK-2_0" || "FLINK-1_15" || "ZEPPELIN-FLINK-3_0" || "FLINK-1_18", // required
58+
* // RuntimeEnvironment: "SQL-1_0" || "FLINK-1_6" || "FLINK-1_8" || "ZEPPELIN-FLINK-1_0" || "FLINK-1_11" || "FLINK-1_13" || "ZEPPELIN-FLINK-2_0" || "FLINK-1_15" || "ZEPPELIN-FLINK-3_0" || "FLINK-1_18" || "FLINK-1_19", // required
5959
* // ServiceExecutionRole: "STRING_VALUE",
6060
* // ApplicationStatus: "DELETING" || "STARTING" || "STOPPING" || "READY" || "RUNNING" || "UPDATING" || "AUTOSCALING" || "FORCE_STOPPING" || "ROLLING_BACK" || "MAINTENANCE" || "ROLLED_BACK", // required
6161
* // ApplicationVersionId: Number("long"), // required

‎clients/client-kinesis-analytics-v2/src/commands/UpdateApplicationCommand.ts

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -247,7 +247,7 @@ export interface UpdateApplicationCommandOutput extends UpdateApplicationRespons
247247
* },
248248
* ],
249249
* ConditionalToken: "STRING_VALUE",
250-
* RuntimeEnvironmentUpdate: "SQL-1_0" || "FLINK-1_6" || "FLINK-1_8" || "ZEPPELIN-FLINK-1_0" || "FLINK-1_11" || "FLINK-1_13" || "ZEPPELIN-FLINK-2_0" || "FLINK-1_15" || "ZEPPELIN-FLINK-3_0" || "FLINK-1_18",
250+
* RuntimeEnvironmentUpdate: "SQL-1_0" || "FLINK-1_6" || "FLINK-1_8" || "ZEPPELIN-FLINK-1_0" || "FLINK-1_11" || "FLINK-1_13" || "ZEPPELIN-FLINK-2_0" || "FLINK-1_15" || "ZEPPELIN-FLINK-3_0" || "FLINK-1_18" || "FLINK-1_19",
251251
* };
252252
* const command = new UpdateApplicationCommand(input);
253253
* const response = await client.send(command);
@@ -256,7 +256,7 @@ export interface UpdateApplicationCommandOutput extends UpdateApplicationRespons
256256
* // ApplicationARN: "STRING_VALUE", // required
257257
* // ApplicationDescription: "STRING_VALUE",
258258
* // ApplicationName: "STRING_VALUE", // required
259-
* // RuntimeEnvironment: "SQL-1_0" || "FLINK-1_6" || "FLINK-1_8" || "ZEPPELIN-FLINK-1_0" || "FLINK-1_11" || "FLINK-1_13" || "ZEPPELIN-FLINK-2_0" || "FLINK-1_15" || "ZEPPELIN-FLINK-3_0" || "FLINK-1_18", // required
259+
* // RuntimeEnvironment: "SQL-1_0" || "FLINK-1_6" || "FLINK-1_8" || "ZEPPELIN-FLINK-1_0" || "FLINK-1_11" || "FLINK-1_13" || "ZEPPELIN-FLINK-2_0" || "FLINK-1_15" || "ZEPPELIN-FLINK-3_0" || "FLINK-1_18" || "FLINK-1_19", // required
260260
* // ServiceExecutionRole: "STRING_VALUE",
261261
* // ApplicationStatus: "DELETING" || "STARTING" || "STOPPING" || "READY" || "RUNNING" || "UPDATING" || "AUTOSCALING" || "FORCE_STOPPING" || "ROLLING_BACK" || "MAINTENANCE" || "ROLLED_BACK", // required
262262
* // ApplicationVersionId: Number("long"), // required

‎clients/client-kinesis-analytics-v2/src/models/models_0.ts

Lines changed: 10 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -1733,9 +1733,9 @@ export type ConfigurationType = (typeof ConfigurationType)[keyof typeof Configur
17331733
* <p>Describes an application's checkpointing configuration. Checkpointing is the process of persisting application state for fault
17341734
* tolerance.
17351735
* For more information, see
1736-
* <a href="https://nightlies.apache.org/flink/flink-docs-release-1.18/docs/dev/datastream/fault-tolerance/checkpointing/#enabling-and-configuring-checkpointing">
1736+
* <a href="https://nightlies.apache.org/flink/flink-docs-release-1.19/docs/dev/datastream/fault-tolerance/checkpointing/#enabling-and-configuring-checkpointing">
17371737
* Checkpoints for Fault Tolerance</a> in the
1738-
* <a href="https://nightlies.apache.org/flink/flink-docs-release-1.18/">Apache Flink Documentation</a>.</p>
1738+
* <a href="https://nightlies.apache.org/flink/flink-docs-release-1.19/">Apache Flink Documentation</a>.</p>
17391739
* @public
17401740
*/
17411741
export interface CheckpointConfiguration {
@@ -1791,7 +1791,7 @@ export interface CheckpointConfiguration {
17911791
* <p>Describes the minimum time in milliseconds after a checkpoint operation completes that a
17921792
* new checkpoint operation can start. If a checkpoint operation takes longer than the
17931793
* <code>CheckpointInterval</code>, the application otherwise performs continual checkpoint
1794-
* operations. For more information, see <a href="https://nightlies.apache.org/flink/flink-docs-release-1.18/docs/ops/state/large_state_tuning/#tuning-checkpointing"> Tuning Checkpointing</a> in the <a href="https://nightlies.apache.org/flink/flink-docs-release-1.18/">Apache Flink
1794+
* operations. For more information, see <a href="https://nightlies.apache.org/flink/flink-docs-release-1.19/docs/ops/state/large_state_tuning/#tuning-checkpointing"> Tuning Checkpointing</a> in the <a href="https://nightlies.apache.org/flink/flink-docs-release-1.19/">Apache Flink
17951795
* Documentation</a>.</p>
17961796
* <note>
17971797
* <p>If <code>CheckpointConfiguration.ConfigurationType</code> is <code>DEFAULT</code>,
@@ -1865,7 +1865,7 @@ export interface MonitoringConfiguration {
18651865
/**
18661866
* <p>Describes parameters for how a Managed Service for Apache Flink application
18671867
* executes multiple tasks simultaneously. For more information about parallelism,
1868-
* see <a href="https://nightlies.apache.org/flink/flink-docs-release-1.18/dev/parallel.html">Parallel Execution</a> in the <a href="https://nightlies.apache.org/flink/flink-docs-release-1.18/">Apache Flink
1868+
* see <a href="https://nightlies.apache.org/flink/flink-docs-release-1.19/dev/parallel.html">Parallel Execution</a> in the <a href="https://nightlies.apache.org/flink/flink-docs-release-1.19/">Apache Flink
18691869
* Documentation</a>.</p>
18701870
* @public
18711871
*/
@@ -1913,9 +1913,9 @@ export interface FlinkApplicationConfiguration {
19131913
* <p>Describes an application's checkpointing configuration. Checkpointing is the
19141914
* process of persisting application state for fault tolerance.
19151915
* For more information, see
1916-
* <a href="https://nightlies.apache.org/flink/flink-docs-release-1.18/docs/dev/datastream/fault-tolerance/checkpointing/#enabling-and-configuring-checkpointing">
1916+
* <a href="https://nightlies.apache.org/flink/flink-docs-release-1.19/docs/dev/datastream/fault-tolerance/checkpointing/#enabling-and-configuring-checkpointing">
19171917
* Checkpoints for Fault Tolerance</a> in the
1918-
* <a href="https://nightlies.apache.org/flink/flink-docs-release-1.18/">Apache Flink Documentation</a>. </p>
1918+
* <a href="https://nightlies.apache.org/flink/flink-docs-release-1.19/">Apache Flink Documentation</a>. </p>
19191919
* @public
19201920
*/
19211921
CheckpointConfiguration?: CheckpointConfiguration;
@@ -2375,7 +2375,7 @@ export interface FlinkApplicationConfigurationDescription {
23752375
ParallelismConfigurationDescription?: ParallelismConfigurationDescription;
23762376

23772377
/**
2378-
* <p>The job plan for an application. For more information about the job plan, see <a href="https://nightlies.apache.org/flink/flink-docs-release-1.18/internals/job_scheduling.html">Jobs and Scheduling</a> in the <a href="https://nightlies.apache.org/flink/flink-docs-release-1.18/">Apache Flink
2378+
* <p>The job plan for an application. For more information about the job plan, see <a href="https://nightlies.apache.org/flink/flink-docs-release-1.19/internals/job_scheduling.html">Jobs and Scheduling</a> in the <a href="https://nightlies.apache.org/flink/flink-docs-release-1.19/">Apache Flink
23792379
* Documentation</a>. To retrieve the job plan for the application, use the <a>DescribeApplicationRequest$IncludeAdditionalDetails</a> parameter of the <a>DescribeApplication</a> operation.</p>
23802380
* @public
23812381
*/
@@ -2428,8 +2428,8 @@ export interface FlinkRunConfiguration {
24282428
* This will happen if the program is updated between snapshots to remove stateful parameters, and
24292429
* state data in the snapshot no longer
24302430
* corresponds to valid application data. For more information, see
2431-
* <a href="https://nightlies.apache.org/flink/flink-docs-release-1.18/docs/ops/state/savepoints/#allowing-non-restored-state">
2432-
* Allowing Non-Restored State</a> in the <a href="https://nightlies.apache.org/flink/flink-docs-release-1.18/">Apache Flink
2431+
* <a href="https://nightlies.apache.org/flink/flink-docs-release-1.19/docs/ops/state/savepoints/#allowing-non-restored-state">
2432+
* Allowing Non-Restored State</a> in the <a href="https://nightlies.apache.org/flink/flink-docs-release-1.19/">Apache Flink
24332433
* documentation</a>.</p>
24342434
* <note>
24352435
* <p>This value defaults to <code>false</code>. If you update your application without
@@ -3434,6 +3434,7 @@ export const RuntimeEnvironment = {
34343434
FLINK_1_13: "FLINK-1_13",
34353435
FLINK_1_15: "FLINK-1_15",
34363436
FLINK_1_18: "FLINK-1_18",
3437+
FLINK_1_19: "FLINK-1_19",
34373438
FLINK_1_6: "FLINK-1_6",
34383439
FLINK_1_8: "FLINK-1_8",
34393440
SQL_1_0: "SQL-1_0",

0 commit comments

Comments
 (0)