diff --git a/pkg/kubelet/kubelet_test.go b/pkg/kubelet/kubelet_test.go
index 517129b7c38..a9185fb80eb 100644
--- a/pkg/kubelet/kubelet_test.go
+++ b/pkg/kubelet/kubelet_test.go
@@ -887,7 +887,12 @@ func TestWatchEtcd(t *testing.T) {
 	data, err := json.Marshal(manifest)
 	expectNoError(t, err)
 
-	go kubelet.WatchEtcd(watchChannel, updateChannel)
+	var wg sync.WaitGroup
+	wg.Add(1)
+	go func() {
+		kubelet.WatchEtcd(watchChannel, updateChannel)
+		wg.Done()
+	}()
 
 	watchChannel <- &etcd.Response{
 		Node: &etcd.Node{
@@ -895,6 +900,7 @@ func TestWatchEtcd(t *testing.T) {
 		},
 	}
 	close(watchChannel)
+	wg.Wait()
 	close(updateChannel)
 
 	read := reader.GetList()