feat(client-kinesis-analytics-v2): Support for Flink 1.18 in Managed …

…Service for Apache Flink
aws · Mar 15, 2024 · d93457b · d93457b
1 parent 7077749
commit d93457b
Show file tree

Hide file tree

Showing 10 changed files with 32 additions and 25 deletions.
diff --git a/clients/client-kinesis-analytics-v2/src/commands/CreateApplicationCommand.ts b/clients/client-kinesis-analytics-v2/src/commands/CreateApplicationCommand.ts
@@ -43,7 +43,7 @@ export interface CreateApplicationCommandOutput extends CreateApplicationRespons
  * const input = { // CreateApplicationRequest
  *   ApplicationName: "STRING_VALUE", // required
  *   ApplicationDescription: "STRING_VALUE",
- *   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
+ *   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
  *   ServiceExecutionRole: "STRING_VALUE", // required
  *   ApplicationConfiguration: { // ApplicationConfiguration
  *     SqlApplicationConfiguration: { // SqlApplicationConfiguration
@@ -243,7 +243,7 @@ export interface CreateApplicationCommandOutput extends CreateApplicationRespons
  * //     ApplicationARN: "STRING_VALUE", // required
  * //     ApplicationDescription: "STRING_VALUE",
  * //     ApplicationName: "STRING_VALUE", // required
- * //     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
+ * //     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
  * //     ServiceExecutionRole: "STRING_VALUE",
  * //     ApplicationStatus: "DELETING" || "STARTING" || "STOPPING" || "READY" || "RUNNING" || "UPDATING" || "AUTOSCALING" || "FORCE_STOPPING" || "ROLLING_BACK" || "MAINTENANCE" || "ROLLED_BACK", // required
  * //     ApplicationVersionId: Number("long"), // required

diff --git a/clients/client-kinesis-analytics-v2/src/commands/DescribeApplicationCommand.ts b/clients/client-kinesis-analytics-v2/src/commands/DescribeApplicationCommand.ts
@@ -51,7 +51,7 @@ export interface DescribeApplicationCommandOutput extends DescribeApplicationRes
  * //     ApplicationARN: "STRING_VALUE", // required
  * //     ApplicationDescription: "STRING_VALUE",
  * //     ApplicationName: "STRING_VALUE", // required
- * //     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
+ * //     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
  * //     ServiceExecutionRole: "STRING_VALUE",
  * //     ApplicationStatus: "DELETING" || "STARTING" || "STOPPING" || "READY" || "RUNNING" || "UPDATING" || "AUTOSCALING" || "FORCE_STOPPING" || "ROLLING_BACK" || "MAINTENANCE" || "ROLLED_BACK", // required
  * //     ApplicationVersionId: Number("long"), // required

diff --git a/clients/client-kinesis-analytics-v2/src/commands/DescribeApplicationSnapshotCommand.ts b/clients/client-kinesis-analytics-v2/src/commands/DescribeApplicationSnapshotCommand.ts
@@ -52,7 +52,7 @@ export interface DescribeApplicationSnapshotCommandOutput
  * //     SnapshotStatus: "CREATING" || "READY" || "DELETING" || "FAILED", // required
  * //     ApplicationVersionId: Number("long"), // required
  * //     SnapshotCreationTimestamp: new Date("TIMESTAMP"),
- * //     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",
+ * //     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",
  * //   },
  * // };
  *

diff --git a/clients/client-kinesis-analytics-v2/src/commands/DescribeApplicationVersionCommand.ts b/clients/client-kinesis-analytics-v2/src/commands/DescribeApplicationVersionCommand.ts
@@ -52,7 +52,7 @@ export interface DescribeApplicationVersionCommandOutput extends DescribeApplica
  * //     ApplicationARN: "STRING_VALUE", // required
  * //     ApplicationDescription: "STRING_VALUE",
  * //     ApplicationName: "STRING_VALUE", // required
- * //     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
+ * //     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
  * //     ServiceExecutionRole: "STRING_VALUE",
  * //     ApplicationStatus: "DELETING" || "STARTING" || "STOPPING" || "READY" || "RUNNING" || "UPDATING" || "AUTOSCALING" || "FORCE_STOPPING" || "ROLLING_BACK" || "MAINTENANCE" || "ROLLED_BACK", // required
  * //     ApplicationVersionId: Number("long"), // required

diff --git a/clients/client-kinesis-analytics-v2/src/commands/ListApplicationSnapshotsCommand.ts b/clients/client-kinesis-analytics-v2/src/commands/ListApplicationSnapshotsCommand.ts
@@ -52,7 +52,7 @@ export interface ListApplicationSnapshotsCommandOutput extends ListApplicationSn
  * //       SnapshotStatus: "CREATING" || "READY" || "DELETING" || "FAILED", // required
  * //       ApplicationVersionId: Number("long"), // required
  * //       SnapshotCreationTimestamp: new Date("TIMESTAMP"),
- * //       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",
+ * //       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",
  * //     },
  * //   ],
  * //   NextToken: "STRING_VALUE",

diff --git a/clients/client-kinesis-analytics-v2/src/commands/ListApplicationsCommand.ts b/clients/client-kinesis-analytics-v2/src/commands/ListApplicationsCommand.ts
@@ -55,7 +55,7 @@ export interface ListApplicationsCommandOutput extends ListApplicationsResponse,
  * //       ApplicationARN: "STRING_VALUE", // required
  * //       ApplicationStatus: "DELETING" || "STARTING" || "STOPPING" || "READY" || "RUNNING" || "UPDATING" || "AUTOSCALING" || "FORCE_STOPPING" || "ROLLING_BACK" || "MAINTENANCE" || "ROLLED_BACK", // required
  * //       ApplicationVersionId: Number("long"), // required
- * //       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
+ * //       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
  * //       ApplicationMode: "STREAMING" || "INTERACTIVE",
  * //     },
  * //   ],

diff --git a/clients/client-kinesis-analytics-v2/src/commands/RollbackApplicationCommand.ts b/clients/client-kinesis-analytics-v2/src/commands/RollbackApplicationCommand.ts
@@ -55,7 +55,7 @@ export interface RollbackApplicationCommandOutput extends RollbackApplicationRes
  * //     ApplicationARN: "STRING_VALUE", // required
  * //     ApplicationDescription: "STRING_VALUE",
  * //     ApplicationName: "STRING_VALUE", // required
- * //     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
+ * //     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
  * //     ServiceExecutionRole: "STRING_VALUE",
  * //     ApplicationStatus: "DELETING" || "STARTING" || "STOPPING" || "READY" || "RUNNING" || "UPDATING" || "AUTOSCALING" || "FORCE_STOPPING" || "ROLLING_BACK" || "MAINTENANCE" || "ROLLED_BACK", // required
  * //     ApplicationVersionId: Number("long"), // required

diff --git a/clients/client-kinesis-analytics-v2/src/commands/UpdateApplicationCommand.ts b/clients/client-kinesis-analytics-v2/src/commands/UpdateApplicationCommand.ts
@@ -243,7 +243,7 @@ export interface UpdateApplicationCommandOutput extends UpdateApplicationRespons
  *     },
  *   ],
  *   ConditionalToken: "STRING_VALUE",
- *   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",
+ *   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",
  * };
  * const command = new UpdateApplicationCommand(input);
  * const response = await client.send(command);
@@ -252,7 +252,7 @@ export interface UpdateApplicationCommandOutput extends UpdateApplicationRespons
  * //     ApplicationARN: "STRING_VALUE", // required
  * //     ApplicationDescription: "STRING_VALUE",
  * //     ApplicationName: "STRING_VALUE", // required
- * //     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
+ * //     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
  * //     ServiceExecutionRole: "STRING_VALUE",
  * //     ApplicationStatus: "DELETING" || "STARTING" || "STOPPING" || "READY" || "RUNNING" || "UPDATING" || "AUTOSCALING" || "FORCE_STOPPING" || "ROLLING_BACK" || "MAINTENANCE" || "ROLLED_BACK", // required
  * //     ApplicationVersionId: Number("long"), // required

diff --git a/clients/client-kinesis-analytics-v2/src/models/models_0.ts b/clients/client-kinesis-analytics-v2/src/models/models_0.ts
@@ -1714,9 +1714,9 @@ export type ConfigurationType = (typeof ConfigurationType)[keyof typeof Configur
  * <p>Describes an application's checkpointing configuration. Checkpointing is the process of persisting application state for fault
  *       tolerance.
  *       For more information, see
- *       <a href="https://ci.apache.org/projects/flink/flink-docs-release-1.8/concepts/programming-model.html#checkpoints-for-fault-tolerance">
+ *       <a href="https://nightlies.apache.org/flink/flink-docs-release-1.18/docs/dev/datastream/fault-tolerance/checkpointing/#enabling-and-configuring-checkpointing">
  *         Checkpoints for Fault Tolerance</a> in the
- *       <a href="https://ci.apache.org/projects/flink/flink-docs-release-1.8/">Apache Flink Documentation</a>.</p>
+ *       <a href="https://nightlies.apache.org/flink/flink-docs-release-1.18/">Apache Flink Documentation</a>.</p>
  * @public
  */
 export interface CheckpointConfiguration {
@@ -1772,7 +1772,7 @@ export interface CheckpointConfiguration {
    * <p>Describes the minimum time in milliseconds after a checkpoint operation completes that a
    *       new checkpoint operation can start. If a checkpoint operation takes longer than the
    *         <code>CheckpointInterval</code>, the application otherwise performs continual checkpoint
-   *       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
+   *       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
    *         Documentation</a>.</p>
    *          <note>
    *             <p>If <code>CheckpointConfiguration.ConfigurationType</code> is <code>DEFAULT</code>,
@@ -1846,7 +1846,7 @@ export interface MonitoringConfiguration {
 /**
  * <p>Describes parameters for how a Managed Service for Apache Flink application
  *       executes multiple tasks simultaneously. For more information about parallelism,
- *       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
+ *       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
  *         Documentation</a>.</p>
  * @public
  */
@@ -1894,9 +1894,9 @@ export interface FlinkApplicationConfiguration {
    * <p>Describes an application's checkpointing configuration. Checkpointing is the
    *       process of persisting application state for fault tolerance.
    *       For more information, see
-   *       <a href="https://ci.apache.org/projects/flink/flink-docs-release-1.8/concepts/programming-model.html#checkpoints-for-fault-tolerance">
+   *       <a href="https://nightlies.apache.org/flink/flink-docs-release-1.18/docs/dev/datastream/fault-tolerance/checkpointing/#enabling-and-configuring-checkpointing">
    *         Checkpoints for Fault Tolerance</a> in the
-   *       <a href="https://ci.apache.org/projects/flink/flink-docs-release-1.8/">Apache Flink Documentation</a>. </p>
+   *       <a href="https://nightlies.apache.org/flink/flink-docs-release-1.18/">Apache Flink Documentation</a>. </p>
    * @public
    */
   CheckpointConfiguration?: CheckpointConfiguration;
@@ -2338,7 +2338,7 @@ export interface FlinkApplicationConfigurationDescription {
   ParallelismConfigurationDescription?: ParallelismConfigurationDescription;
 
   /**
-   * <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
+   * <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
    *         Documentation</a>. To retrieve the job plan for the application, use the <a>DescribeApplicationRequest$IncludeAdditionalDetails</a> parameter of the <a>DescribeApplication</a> operation.</p>
    * @public
    */
@@ -2391,8 +2391,8 @@ export interface FlinkRunConfiguration {
    *      This will happen if the program is updated between snapshots to remove stateful parameters, and
    *      state data in the snapshot no longer
    *      corresponds to valid application data. For more information, see
-   *      <a href="https://ci.apache.org/projects/flink/flink-docs-release-1.8/ops/state/savepoints.html#allowing-non-restored-state">
-   *        Allowing Non-Restored State</a> in the <a href="https://ci.apache.org/projects/flink/flink-docs-release-1.8/">Apache Flink
+   *      <a href="https://nightlies.apache.org/flink/flink-docs-release-1.18/docs/ops/state/savepoints/#allowing-non-restored-state">
+   *        Allowing Non-Restored State</a> in the <a href="https://nightlies.apache.org/flink/flink-docs-release-1.18/">Apache Flink
    *          documentation</a>.</p>
    *          <note>
    *             <p>This value defaults to <code>false</code>. If you update your application without
@@ -3372,6 +3372,7 @@ export const RuntimeEnvironment = {
   FLINK_1_11: "FLINK-1_11",
   FLINK_1_13: "FLINK-1_13",
   FLINK_1_15: "FLINK-1_15",
+  FLINK_1_18: "FLINK-1_18",
   FLINK_1_6: "FLINK-1_6",
   FLINK_1_8: "FLINK-1_8",
   SQL_1_0: "SQL-1_0",