@@ -1283,20 +1283,6 @@ func resourceApplicationUpdate(ctx context.Context, d *schema.ResourceData, meta
1283
1283
}
1284
1284
}
1285
1285
1286
- if d .HasChange ("application_configuration.0.run_configuration" ) {
1287
- application , err := findApplicationDetailByName (ctx , conn , applicationName )
1288
-
1289
- if err != nil {
1290
- return sdkdiag .AppendErrorf (diags , "reading Kinesis Analytics v2 Application (%s): %s" , applicationName , err )
1291
- }
1292
-
1293
- if actual , expected := application .ApplicationStatus , awstypes .ApplicationStatusRunning ; actual == expected {
1294
- input .RunConfigurationUpdate = expandRunConfigurationUpdate (d .Get ("application_configuration.0.run_configuration" ).([]any ))
1295
-
1296
- updateApplication = true
1297
- }
1298
- }
1299
-
1300
1286
input .ApplicationConfigurationUpdate = applicationConfigurationUpdate
1301
1287
}
1302
1288
@@ -1392,6 +1378,17 @@ func resourceApplicationUpdate(ctx context.Context, d *schema.ResourceData, meta
1392
1378
}
1393
1379
1394
1380
if updateApplication {
1381
+ // Always send 'run_configuration', else defaults are applied.
1382
+ application , err := findApplicationDetailByName (ctx , conn , applicationName )
1383
+
1384
+ if err != nil {
1385
+ return sdkdiag .AppendErrorf (diags , "reading Kinesis Analytics v2 Application (%s): %s" , applicationName , err )
1386
+ }
1387
+
1388
+ if actual , expected := application .ApplicationStatus , awstypes .ApplicationStatusRunning ; actual == expected {
1389
+ input .RunConfigurationUpdate = expandRunConfigurationUpdate (d .Get ("application_configuration.0.run_configuration" ).([]any ))
1390
+ }
1391
+
1395
1392
input .CurrentApplicationVersionId = aws .Int64 (currentApplicationVersionID )
1396
1393
1397
1394
output , err := waitIAMPropagation (ctx , func () (* kinesisanalyticsv2.UpdateApplicationOutput , error ) {
0 commit comments