diff --git a/test/e2e/testsuites/dynamically_provisioned_restart_driver_tester.go b/test/e2e/testsuites/dynamically_provisioned_restart_driver_tester.go
index 251f0cb59..c7bf98fe2 100644
--- a/test/e2e/testsuites/dynamically_provisioned_restart_driver_tester.go
+++ b/test/e2e/testsuites/dynamically_provisioned_restart_driver_tester.go
@@ -102,7 +102,7 @@ func (t *DynamicallyProvisionedRestartDriverTest) Run(client clientset.Interface
 	t.RestartDriverFunc()
 
 	// restart completed, notify all goroutine to continue checking
-	restartCompleted <- struct{}{}
+	close(restartCompleted)
 
 	// wait for cleanup finish
 	wg.Wait()