From d93457b7f5c7983f6f9e4be7f27ada3b10077207 Mon Sep 17 00:00:00 2001
From: awstools
Date: Fri, 15 Mar 2024 18:23:47 +0000
Subject: [PATCH] feat(client-kinesis-analytics-v2): Support for Flink 1.18 in
Managed Service for Apache Flink
---
.../src/commands/CreateApplicationCommand.ts | 4 ++--
.../commands/DescribeApplicationCommand.ts | 2 +-
.../DescribeApplicationSnapshotCommand.ts | 2 +-
.../DescribeApplicationVersionCommand.ts | 2 +-
.../ListApplicationSnapshotsCommand.ts | 2 +-
.../src/commands/ListApplicationsCommand.ts | 2 +-
.../commands/RollbackApplicationCommand.ts | 2 +-
.../src/commands/UpdateApplicationCommand.ts | 4 ++--
.../src/models/models_0.ts | 19 ++++++++++---------
.../aws-models/kinesis-analytics-v2.json | 18 ++++++++++++------
10 files changed, 32 insertions(+), 25 deletions(-)
diff --git a/clients/client-kinesis-analytics-v2/src/commands/CreateApplicationCommand.ts b/clients/client-kinesis-analytics-v2/src/commands/CreateApplicationCommand.ts
index e8dd9bc613a7..fdd928d62908 100644
--- 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
index 108ff733f4bc..72f8c263e2f1 100644
--- 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
index 6b4b5f75abcf..dd8bc79d1bd8 100644
--- 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
index f932a841459e..a5fe23b40d73 100644
--- 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
index 0c8b0315734d..96ea93ffc41e 100644
--- 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
index 045a080ac71e..4b2d9b1c7ddb 100644
--- 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
index dcdf8bc09fa2..76a55096378a 100644
--- 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
index a50b433a69ef..6af7e121eaba 100644
--- 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
index 7325db602f24..981114df08bb 100644
--- 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
* Describes an application's checkpointing configuration. Checkpointing is the process of persisting application state for fault
* tolerance.
* For more information, see
- *
+ *
* Checkpoints for Fault Tolerance in the
- * Apache Flink Documentation.
+ * Apache Flink Documentation.
* @public
*/
export interface CheckpointConfiguration {
@@ -1772,7 +1772,7 @@ export interface CheckpointConfiguration {
* 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
* CheckpointInterval
, the application otherwise performs continual checkpoint
- * operations. For more information, see Tuning Checkpointing in the Apache Flink
+ * operations. For more information, see Tuning Checkpointing in the Apache Flink
* Documentation.
*
* If CheckpointConfiguration.ConfigurationType
is DEFAULT
,
@@ -1846,7 +1846,7 @@ export interface MonitoringConfiguration {
/**
*
Describes parameters for how a Managed Service for Apache Flink application
* executes multiple tasks simultaneously. For more information about parallelism,
- * see Parallel Execution in the Apache Flink
+ * see Parallel Execution in the Apache Flink
* Documentation.
* @public
*/
@@ -1894,9 +1894,9 @@ export interface FlinkApplicationConfiguration {
* Describes an application's checkpointing configuration. Checkpointing is the
* process of persisting application state for fault tolerance.
* For more information, see
- *
+ *
* Checkpoints for Fault Tolerance in the
- * Apache Flink Documentation.
+ * Apache Flink Documentation.
* @public
*/
CheckpointConfiguration?: CheckpointConfiguration;
@@ -2338,7 +2338,7 @@ export interface FlinkApplicationConfigurationDescription {
ParallelismConfigurationDescription?: ParallelismConfigurationDescription;
/**
- * The job plan for an application. For more information about the job plan, see Jobs and Scheduling in the Apache Flink
+ * The job plan for an application. For more information about the job plan, see Jobs and Scheduling in the Apache Flink
* Documentation. To retrieve the job plan for the application, use the DescribeApplicationRequest$IncludeAdditionalDetails parameter of the DescribeApplication operation.
* @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
- *
- * Allowing Non-Restored State in the Apache Flink
+ *
+ * Allowing Non-Restored State in the Apache Flink
* documentation.
*
* This value defaults to false
. 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",
diff --git a/codegen/sdk-codegen/aws-models/kinesis-analytics-v2.json b/codegen/sdk-codegen/aws-models/kinesis-analytics-v2.json
index b5b348801043..771c9d3cbf95 100644
--- a/codegen/sdk-codegen/aws-models/kinesis-analytics-v2.json
+++ b/codegen/sdk-codegen/aws-models/kinesis-analytics-v2.json
@@ -1381,12 +1381,12 @@
"MinPauseBetweenCheckpoints": {
"target": "com.amazonaws.kinesisanalyticsv2#MinPauseBetweenCheckpoints",
"traits": {
- "smithy.api#documentation": "
Describes the minimum time in milliseconds after a checkpoint operation completes that a\n new checkpoint operation can start. If a checkpoint operation takes longer than the\n CheckpointInterval
, the application otherwise performs continual checkpoint\n operations. For more information, see Tuning Checkpointing in the Apache Flink\n Documentation.
\n \n If CheckpointConfiguration.ConfigurationType
is DEFAULT
,\n the application will use a MinPauseBetweenCheckpoints
value of 5000, even if this value is set using this \n API or in application code.
\n "
+ "smithy.api#documentation": "Describes the minimum time in milliseconds after a checkpoint operation completes that a\n new checkpoint operation can start. If a checkpoint operation takes longer than the\n CheckpointInterval
, the application otherwise performs continual checkpoint\n operations. For more information, see Tuning Checkpointing in the Apache Flink\n Documentation.
\n \n If CheckpointConfiguration.ConfigurationType
is DEFAULT
,\n the application will use a MinPauseBetweenCheckpoints
value of 5000, even if this value is set using this \n API or in application code.
\n "
}
}
},
"traits": {
- "smithy.api#documentation": "Describes an application's checkpointing configuration. Checkpointing is the process of persisting application state for fault \n tolerance.\n For more information, see \n \n Checkpoints for Fault Tolerance in the \n Apache Flink Documentation.
"
+ "smithy.api#documentation": "Describes an application's checkpointing configuration. Checkpointing is the process of persisting application state for fault \n tolerance.\n For more information, see \n \n Checkpoints for Fault Tolerance in the\n Apache Flink Documentation.
"
}
},
"com.amazonaws.kinesisanalyticsv2#CheckpointConfigurationDescription": {
@@ -2972,7 +2972,7 @@
"CheckpointConfiguration": {
"target": "com.amazonaws.kinesisanalyticsv2#CheckpointConfiguration",
"traits": {
- "smithy.api#documentation": "Describes an application's checkpointing configuration. Checkpointing is the \n process of persisting application state for fault tolerance.\n For more information, see \n \n Checkpoints for Fault Tolerance in the \n Apache Flink Documentation.
"
+ "smithy.api#documentation": "Describes an application's checkpointing configuration. Checkpointing is the \n process of persisting application state for fault tolerance.\n For more information, see \n \n Checkpoints for Fault Tolerance in the \n Apache Flink Documentation.
"
}
},
"MonitoringConfiguration": {
@@ -3016,7 +3016,7 @@
"JobPlanDescription": {
"target": "com.amazonaws.kinesisanalyticsv2#JobPlanDescription",
"traits": {
- "smithy.api#documentation": "The job plan for an application. For more information about the job plan, see Jobs and Scheduling in the Apache Flink\n Documentation. To retrieve the job plan for the application, use the DescribeApplicationRequest$IncludeAdditionalDetails parameter of the DescribeApplication operation.
"
+ "smithy.api#documentation": "The job plan for an application. For more information about the job plan, see Jobs and Scheduling in the Apache Flink\n Documentation. To retrieve the job plan for the application, use the DescribeApplicationRequest$IncludeAdditionalDetails parameter of the DescribeApplication operation.
"
}
}
},
@@ -3056,7 +3056,7 @@
"AllowNonRestoredState": {
"target": "com.amazonaws.kinesisanalyticsv2#BooleanObject",
"traits": {
- "smithy.api#documentation": "When restoring from a snapshot, specifies whether the runtime is allowed to skip a state that cannot \n be mapped to the new program.\n This will happen if the program is updated between snapshots to remove stateful parameters, and \n state data in the snapshot no longer \n corresponds to valid application data. For more information, see \n \n Allowing Non-Restored State in the Apache Flink \n documentation.
\n \n This value defaults to false
. If you update your application without\n specifying this parameter, AllowNonRestoredState
will be set to false
,\n even if it was previously set to true
.
\n "
+ "smithy.api#documentation": "When restoring from a snapshot, specifies whether the runtime is allowed to skip a state that cannot \n be mapped to the new program.\n This will happen if the program is updated between snapshots to remove stateful parameters, and \n state data in the snapshot no longer \n corresponds to valid application data. For more information, see \n \n Allowing Non-Restored State in the Apache Flink\n documentation.
\n \n This value defaults to false
. If you update your application without\n specifying this parameter, AllowNonRestoredState
will be set to false
,\n even if it was previously set to true
.
\n "
}
}
},
@@ -5591,7 +5591,7 @@
}
},
"traits": {
- "smithy.api#documentation": "Describes parameters for how a Managed Service for Apache Flink application\n executes multiple tasks simultaneously. For more information about parallelism,\n see Parallel Execution in the Apache Flink\n Documentation.
"
+ "smithy.api#documentation": "Describes parameters for how a Managed Service for Apache Flink application\n executes multiple tasks simultaneously. For more information about parallelism,\n see Parallel Execution in the Apache Flink\n Documentation.
"
}
},
"com.amazonaws.kinesisanalyticsv2#ParallelismConfigurationDescription": {
@@ -6273,6 +6273,12 @@
"traits": {
"smithy.api#enumValue": "ZEPPELIN-FLINK-3_0"
}
+ },
+ "FLINK_1_18": {
+ "target": "smithy.api#Unit",
+ "traits": {
+ "smithy.api#enumValue": "FLINK-1_18"
+ }
}
}
},