c, ic := newTestServiceImportCache(t)

	ic.createKubeService(t, c)
	ic.createServiceImport(t, mcsapi.ClusterSetIP, serviceImportVIPs)

	// Check that the service has been assigned ClusterSet IPs.
	ic.checkServiceInstances(t)
}

func TestServiceCreatedAfterImported(t *testing.T) {
	c, ic := newTestServiceImportCache(t)

	ic.createServiceImport(t, mcsapi.ClusterSetIP, serviceImportVIPs)
	ic.createKubeService(t, c)

				clusterSetIPSvc, err := genClusterSetIPService(c)
				if err != nil {
					return err
				}

				// Create a ServiceImport in the cluster with the ClusterSet VIP.
				return createServiceImport(c, clusterSetIPSvc.Spec.ClusterIP, serviceImportGVR)
			})
		}
	}

	err = g.Wait()
	status := "success"
	if err != nil {
		status = "failed"
	}

	end := time.Now()