diff --git a/mmv1/third_party/terraform/services/container/resource_container_cluster.go.erb b/mmv1/third_party/terraform/services/container/resource_container_cluster.go.erb
index 1142bf72d95e..46038341105f 100644
--- a/mmv1/third_party/terraform/services/container/resource_container_cluster.go.erb
+++ b/mmv1/third_party/terraform/services/container/resource_container_cluster.go.erb
@@ -3948,21 +3948,19 @@ func resourceContainerClusterUpdate(d *schema.ResourceData, meta interface{}) er
 	}
 
 	if d.HasChange("fleet") {
-		if fleet, ok := d.GetOk("fleet"); ok {
-			req := &container.UpdateClusterRequest{
-				Update: &container.ClusterUpdate{
-					DesiredFleet: expandFleet(fleet),
-				},
-			}
-                        log.Printf("[INFO] GKE cluster %s fleet config has been updated, fleet=%v, req=%v", fleet, req)
+		req := &container.UpdateClusterRequest{
+			Update: &container.ClusterUpdate{
+				DesiredFleet: expandFleet(d.Get("fleet")),
+			},
+		}
+		log.Printf("[INFO] GKE cluster %s fleet config has been updated, fleet=%v, req=%v", fleet, req)
 
-			updateF := updateFunc(req, "updating GKE fleet config")
-			// Call update serially.
-			if err := transport_tpg.LockedCall(lockKey, updateF); err != nil {
-				return err
-			}
-			log.Printf("[INFO] GKE cluster %s fleet config has been updated", d.Id())
+		updateF := updateFunc(req, "updating GKE fleet config")
+		// Call update serially.
+		if err := transport_tpg.LockedCall(lockKey, updateF); err != nil {
+			return err
 		}
+		log.Printf("[INFO] GKE cluster %s fleet config has been updated", d.Id())
 	}
 
 	if d.HasChange("enable_k8s_beta_apis") {