Skip to content

Commit

Permalink
Fix: use correct component name in reconcile for TaskManager service (#…
Browse files Browse the repository at this point in the history
  • Loading branch information
regadas authored Feb 2, 2023
1 parent 14d8cf5 commit 42b07ed
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion controllers/flinkcluster/flinkcluster_reconciler.go
Original file line number Diff line number Diff line change
Expand Up @@ -234,7 +234,7 @@ func (reconciler *ClusterReconciler) reconcileTaskManagerService(ctx context.Con
desiredTmService.SetResourceVersion(observedTmService.GetResourceVersion())
desiredTmService.Spec.ClusterIP = observedTmService.Spec.ClusterIP
}
return reconciler.reconcileComponent(ctx, "JobManagerService", desiredTmService, observedTmService)
return reconciler.reconcileComponent(ctx, "TaskManagerService", desiredTmService, observedTmService)
}

func (reconciler *ClusterReconciler) createComponent(
Expand Down

0 comments on commit 42b07ed

Please sign in to comment.