func TestJobControllerRaceCondition(t *testing.T) {
	t.Cleanup(setDurationDuringTest(&syncJobBatchPeriod, fastSyncJobBatchPeriod))
	logger, ctx := ktesting.NewTestContext(t)
	job1 := newJob(1, 1, 6, batch.NonIndexedCompletion)
	job1.Name = "job1"
	clientSet := fake.NewSimpleClientset(job1)
	//clientset := clientset.NewForConfigOrDie(&restclient.Config{Host: "", ContentConfig: restclient.ContentConfig{GroupVersion: &schema.GroupVersion{Group: "", Version: "v1"}}})
	fakeClock := clocktesting.NewFakeClock(time.Now())
	jm, informer := newControllerFromClientWithClock(ctx, t, clientSet, controller.NoResyncPeriodFunc, fakeClock)
	jm.podControl = &controller.RealPodControl{
		KubeClient: clientSet,
		Recorder:   testutil.NewFakeRecorder(),
	}
	jm.podStoreSynced = alwaysReady
	jm.jobStoreSynced = alwaysReady
 
	informer.Batch().V1().Jobs().Informer().GetIndexer().Add(job1)
	// 1st reconcile should create a new pod
	err := jm.syncJob(ctx, testutil.GetKey(job1, t))
	time.Sleep(time.Second)
 
	podIndexer := informer.Core().V1().Pods().Informer().GetIndexer()
	assert.NotNil(t, podIndexer)
	podList, err := clientSet.Tracker().List(
		schema.GroupVersionResource{Version: "v1", Resource: "pods"},
		schema.GroupVersionKind{Version: "v1", Kind: "Pod"},
		"default")
	assert.NotNil(t, podList)
	// manually adding the just-created pod from fake clientset memory to informer cache because informer is not started.
        // meanwhile, intentionally not adding the job status update to the informer cache to simulate the situation when the job watch event delayed.
	justCreatedPod := podList.(*v1.PodList).Items[0]
	justCreatedPod.Finalizers = nil
	justCreatedPod.Status.Phase = v1.PodSucceeded
	podIndexer.Add(&justCreatedPod)
	jm.addPod(logger, &justCreatedPod)
	
	// removing the just created pod from fake clientset memory, but the pod will remain inside informer cache
	clientSet.Tracker().Delete(		
		schema.GroupVersionResource{Version: "v1", Resource: "pods"},
		"default", "")
	// 2nd reconcile
	err = jm.syncJob(ctx, testutil.GetKey(job1, t))
	time.Sleep(time.Second)
	podList, err = clientSet.Tracker().List(
		schema.GroupVersionResource{Version: "v1", Resource: "pods"},
		schema.GroupVersionKind{Version: "v1", Kind: "Pod"},
		"default")
 
	// no pod should be created, but it will fail here
	assert.True(t, podList.(*v1.PodList).Items == 0)
}