Remove old flink-app-hash selector from generic service (#211)

lyft · Aug 4, 2020 · d377eb1 · d377eb1
1 parent 7f9f891
commit d377eb1
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/pkg/controller/flinkapplication/flink_state_machine.go b/pkg/controller/flinkapplication/flink_state_machine.go
@@ -679,6 +679,8 @@ func (s *FlinkStateMachine) updateGenericService(ctx context.Context, app *v1bet
 	if service.Spec.Selector[flink.PodDeploymentSelector] != selector {
 		// the service hasn't yet been updated
 		service.Spec.Selector[flink.PodDeploymentSelector] = selector
+		// remove the old app hash selector if it's still present
+		delete(service.Spec.Selector, flink.FlinkAppHash)
 		err = s.k8Cluster.UpdateK8Object(ctx, service)
 		if err != nil {
 			return err