Skip to content

Commit d93457b

Browse files
author
awstools
committed
feat(client-kinesis-analytics-v2): Support for Flink 1.18 in Managed Service for Apache Flink
1 parent 7077749 commit d93457b

10 files changed

+32
-25
lines changed

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

+2-2
Original file line numberDiff line numberDiff line change
@@ -43,7 +43,7 @@ export interface CreateApplicationCommandOutput extends CreateApplicationRespons
4343
* const input = { // CreateApplicationRequest
4444
* ApplicationName: "STRING_VALUE", // required
4545
* ApplicationDescription: "STRING_VALUE",
46-
* 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", // required
46+
* 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
4747
* ServiceExecutionRole: "STRING_VALUE", // required
4848
* ApplicationConfiguration: { // ApplicationConfiguration
4949
* SqlApplicationConfiguration: { // SqlApplicationConfiguration
@@ -243,7 +243,7 @@ export interface CreateApplicationCommandOutput extends CreateApplicationRespons
243243
* // ApplicationARN: "STRING_VALUE", // required
244244
* // ApplicationDescription: "STRING_VALUE",
245245
* // ApplicationName: "STRING_VALUE", // required
246-
* // 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", // required
246+
* // 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
247247
* // ServiceExecutionRole: "STRING_VALUE",
248248
* // ApplicationStatus: "DELETING" || "STARTING" || "STOPPING" || "READY" || "RUNNING" || "UPDATING" || "AUTOSCALING" || "FORCE_STOPPING" || "ROLLING_BACK" || "MAINTENANCE" || "ROLLED_BACK", // required
249249
* // ApplicationVersionId: Number("long"), // required

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

+1-1
Original file line numberDiff line numberDiff line change
@@ -51,7 +51,7 @@ export interface DescribeApplicationCommandOutput extends DescribeApplicationRes
5151
* // ApplicationARN: "STRING_VALUE", // required
5252
* // ApplicationDescription: "STRING_VALUE",
5353
* // ApplicationName: "STRING_VALUE", // required
54-
* // 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", // required
54+
* // 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
5555
* // ServiceExecutionRole: "STRING_VALUE",
5656
* // ApplicationStatus: "DELETING" || "STARTING" || "STOPPING" || "READY" || "RUNNING" || "UPDATING" || "AUTOSCALING" || "FORCE_STOPPING" || "ROLLING_BACK" || "MAINTENANCE" || "ROLLED_BACK", // required
5757
* // ApplicationVersionId: Number("long"), // required

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

+1-1
Original file line numberDiff line numberDiff line change
@@ -52,7 +52,7 @@ export interface DescribeApplicationSnapshotCommandOutput
5252
* // SnapshotStatus: "CREATING" || "READY" || "DELETING" || "FAILED", // required
5353
* // ApplicationVersionId: Number("long"), // required
5454
* // SnapshotCreationTimestamp: new Date("TIMESTAMP"),
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",
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",
5656
* // },
5757
* // };
5858
*

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

+1-1
Original file line numberDiff line numberDiff line change
@@ -52,7 +52,7 @@ export interface DescribeApplicationVersionCommandOutput extends DescribeApplica
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", // 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
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/ListApplicationSnapshotsCommand.ts

+1-1
Original file line numberDiff line numberDiff line change
@@ -52,7 +52,7 @@ export interface ListApplicationSnapshotsCommandOutput extends ListApplicationSn
5252
* // SnapshotStatus: "CREATING" || "READY" || "DELETING" || "FAILED", // required
5353
* // ApplicationVersionId: Number("long"), // required
5454
* // SnapshotCreationTimestamp: new Date("TIMESTAMP"),
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",
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",
5656
* // },
5757
* // ],
5858
* // NextToken: "STRING_VALUE",

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

+1-1
Original file line numberDiff line numberDiff line change
@@ -55,7 +55,7 @@ export interface ListApplicationsCommandOutput extends ListApplicationsResponse,
5555
* // ApplicationARN: "STRING_VALUE", // required
5656
* // ApplicationStatus: "DELETING" || "STARTING" || "STOPPING" || "READY" || "RUNNING" || "UPDATING" || "AUTOSCALING" || "FORCE_STOPPING" || "ROLLING_BACK" || "MAINTENANCE" || "ROLLED_BACK", // required
5757
* // ApplicationVersionId: Number("long"), // 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", // 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
5959
* // ApplicationMode: "STREAMING" || "INTERACTIVE",
6060
* // },
6161
* // ],

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

+1-1
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", // 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
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

+2-2
Original file line numberDiff line numberDiff line change
@@ -243,7 +243,7 @@ export interface UpdateApplicationCommandOutput extends UpdateApplicationRespons
243243
* },
244244
* ],
245245
* ConditionalToken: "STRING_VALUE",
246-
* 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",
246+
* 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",
247247
* };
248248
* const command = new UpdateApplicationCommand(input);
249249
* const response = await client.send(command);
@@ -252,7 +252,7 @@ export interface UpdateApplicationCommandOutput extends UpdateApplicationRespons
252252
* // ApplicationARN: "STRING_VALUE", // required
253253
* // ApplicationDescription: "STRING_VALUE",
254254
* // ApplicationName: "STRING_VALUE", // required
255-
* // 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", // required
255+
* // 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
256256
* // ServiceExecutionRole: "STRING_VALUE",
257257
* // ApplicationStatus: "DELETING" || "STARTING" || "STOPPING" || "READY" || "RUNNING" || "UPDATING" || "AUTOSCALING" || "FORCE_STOPPING" || "ROLLING_BACK" || "MAINTENANCE" || "ROLLED_BACK", // required
258258
* // ApplicationVersionId: Number("long"), // required

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

+10-9
Original file line numberDiff line numberDiff line change
@@ -1714,9 +1714,9 @@ export type ConfigurationType = (typeof ConfigurationType)[keyof typeof Configur
17141714
* <p>Describes an application's checkpointing configuration. Checkpointing is the process of persisting application state for fault
17151715
* tolerance.
17161716
* For more information, see
1717-
* <a href="https://ci.apache.org/projects/flink/flink-docs-release-1.8/concepts/programming-model.html#checkpoints-for-fault-tolerance">
1717+
* <a href="https://nightlies.apache.org/flink/flink-docs-release-1.18/docs/dev/datastream/fault-tolerance/checkpointing/#enabling-and-configuring-checkpointing">
17181718
* Checkpoints for Fault Tolerance</a> in the
1719-
* <a href="https://ci.apache.org/projects/flink/flink-docs-release-1.8/">Apache Flink Documentation</a>.</p>
1719+
* <a href="https://nightlies.apache.org/flink/flink-docs-release-1.18/">Apache Flink Documentation</a>.</p>
17201720
* @public
17211721
*/
17221722
export interface CheckpointConfiguration {
@@ -1772,7 +1772,7 @@ export interface CheckpointConfiguration {
17721772
* <p>Describes the minimum time in milliseconds after a checkpoint operation completes that a
17731773
* new checkpoint operation can start. If a checkpoint operation takes longer than the
17741774
* <code>CheckpointInterval</code>, the application otherwise performs continual checkpoint
1775-
* operations. For more information, see <a href="https://ci.apache.org/projects/flink/flink-docs-release-1.8/ops/state/large_state_tuning.html#tuning-checkpointing"> Tuning Checkpointing</a> in the <a href="https://ci.apache.org/projects/flink/flink-docs-release-1.8/">Apache Flink
1775+
* 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
17761776
* Documentation</a>.</p>
17771777
* <note>
17781778
* <p>If <code>CheckpointConfiguration.ConfigurationType</code> is <code>DEFAULT</code>,
@@ -1846,7 +1846,7 @@ export interface MonitoringConfiguration {
18461846
/**
18471847
* <p>Describes parameters for how a Managed Service for Apache Flink application
18481848
* executes multiple tasks simultaneously. For more information about parallelism,
1849-
* see <a href="https://ci.apache.org/projects/flink/flink-docs-release-1.8/dev/parallel.html">Parallel Execution</a> in the <a href="https://ci.apache.org/projects/flink/flink-docs-release-1.8/">Apache Flink
1849+
* 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
18501850
* Documentation</a>.</p>
18511851
* @public
18521852
*/
@@ -1894,9 +1894,9 @@ export interface FlinkApplicationConfiguration {
18941894
* <p>Describes an application's checkpointing configuration. Checkpointing is the
18951895
* process of persisting application state for fault tolerance.
18961896
* For more information, see
1897-
* <a href="https://ci.apache.org/projects/flink/flink-docs-release-1.8/concepts/programming-model.html#checkpoints-for-fault-tolerance">
1897+
* <a href="https://nightlies.apache.org/flink/flink-docs-release-1.18/docs/dev/datastream/fault-tolerance/checkpointing/#enabling-and-configuring-checkpointing">
18981898
* Checkpoints for Fault Tolerance</a> in the
1899-
* <a href="https://ci.apache.org/projects/flink/flink-docs-release-1.8/">Apache Flink Documentation</a>. </p>
1899+
* <a href="https://nightlies.apache.org/flink/flink-docs-release-1.18/">Apache Flink Documentation</a>. </p>
19001900
* @public
19011901
*/
19021902
CheckpointConfiguration?: CheckpointConfiguration;
@@ -2338,7 +2338,7 @@ export interface FlinkApplicationConfigurationDescription {
23382338
ParallelismConfigurationDescription?: ParallelismConfigurationDescription;
23392339

23402340
/**
2341-
* <p>The job plan for an application. For more information about the job plan, see <a href="https://ci.apache.org/projects/flink/flink-docs-release-1.8/internals/job_scheduling.html">Jobs and Scheduling</a> in the <a href="https://ci.apache.org/projects/flink/flink-docs-release-1.8/">Apache Flink
2341+
* <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
23422342
* Documentation</a>. To retrieve the job plan for the application, use the <a>DescribeApplicationRequest$IncludeAdditionalDetails</a> parameter of the <a>DescribeApplication</a> operation.</p>
23432343
* @public
23442344
*/
@@ -2391,8 +2391,8 @@ export interface FlinkRunConfiguration {
23912391
* This will happen if the program is updated between snapshots to remove stateful parameters, and
23922392
* state data in the snapshot no longer
23932393
* corresponds to valid application data. For more information, see
2394-
* <a href="https://ci.apache.org/projects/flink/flink-docs-release-1.8/ops/state/savepoints.html#allowing-non-restored-state">
2395-
* Allowing Non-Restored State</a> in the <a href="https://ci.apache.org/projects/flink/flink-docs-release-1.8/">Apache Flink
2394+
* <a href="https://nightlies.apache.org/flink/flink-docs-release-1.18/docs/ops/state/savepoints/#allowing-non-restored-state">
2395+
* Allowing Non-Restored State</a> in the <a href="https://nightlies.apache.org/flink/flink-docs-release-1.18/">Apache Flink
23962396
* documentation</a>.</p>
23972397
* <note>
23982398
* <p>This value defaults to <code>false</code>. If you update your application without
@@ -3372,6 +3372,7 @@ export const RuntimeEnvironment = {
33723372
FLINK_1_11: "FLINK-1_11",
33733373
FLINK_1_13: "FLINK-1_13",
33743374
FLINK_1_15: "FLINK-1_15",
3375+
FLINK_1_18: "FLINK-1_18",
33753376
FLINK_1_6: "FLINK-1_6",
33763377
FLINK_1_8: "FLINK-1_8",
33773378
SQL_1_0: "SQL-1_0",

0 commit comments

Comments
 (0)