diff --git a/test/e2e/apimachinery/chunking.go b/test/e2e/apimachinery/chunking.go
index 5fa2cf459f4..06f7269273b 100644
--- a/test/e2e/apimachinery/chunking.go
+++ b/test/e2e/apimachinery/chunking.go
@@ -71,7 +71,7 @@ var _ = SIGDescribe("Servers with support for API chunking", func() {
 				}
 				e2elog.Logf("Got an error creating template %d: %v", i, err)
 			}
-			ginkgo.Fail("Unable to create template %d, exiting", i)
+			e2elog.Fail("Unable to create template %d, exiting", i)
 		})
 	})
 
diff --git a/test/e2e/apimachinery/table_conversion.go b/test/e2e/apimachinery/table_conversion.go
index 6773a47d956..0a0939f7be2 100644
--- a/test/e2e/apimachinery/table_conversion.go
+++ b/test/e2e/apimachinery/table_conversion.go
@@ -100,7 +100,7 @@ var _ = SIGDescribe("Servers with support for Table transformation", func() {
 				}
 				e2elog.Logf("Got an error creating template %d: %v", i, err)
 			}
-			ginkgo.Fail("Unable to create template %d, exiting", i)
+			e2elog.Fail("Unable to create template %d, exiting", i)
 		})
 
 		pagedTable := &metav1beta1.Table{}
diff --git a/test/e2e/framework/ginkgowrapper/wrapper.go b/test/e2e/framework/ginkgowrapper/wrapper.go
index 1cb3de1afdd..0b8e676d8f8 100644
--- a/test/e2e/framework/ginkgowrapper/wrapper.go
+++ b/test/e2e/framework/ginkgowrapper/wrapper.go
@@ -27,6 +27,7 @@ import (
 	"strings"
 
 	"github.com/onsi/ginkgo"
+	e2elog "k8s.io/kubernetes/test/e2e/framework/log"
 )
 
 // FailurePanic is the value that will be panicked from Fail.
@@ -64,7 +65,7 @@ func Fail(message string, callerSkip ...int) {
 		}
 	}()
 
-	ginkgo.Fail(message, skip)
+	e2elog.Fail(message, skip)
 }
 
 // SkipPanic is the value that will be panicked from Skip.
diff --git a/test/e2e/framework/testfiles/testfiles.go b/test/e2e/framework/testfiles/testfiles.go
index f2434925daa..aead7862e5e 100644
--- a/test/e2e/framework/testfiles/testfiles.go
+++ b/test/e2e/framework/testfiles/testfiles.go
@@ -35,6 +35,7 @@ import (
 	"strings"
 
 	"github.com/onsi/ginkgo"
+	e2elog "k8s.io/kubernetes/test/e2e/framework/log"
 )
 
 var filesources []FileSource
@@ -73,7 +74,7 @@ type FileSource interface {
 func ReadOrDie(filePath string) []byte {
 	data, err := Read(filePath)
 	if err != nil {
-		ginkgo.Fail(err.Error(), 1)
+		e2elog.Fail(err.Error(), 1)
 	}
 	return data
 }
@@ -110,7 +111,7 @@ func Exists(filePath string) bool {
 	for _, filesource := range filesources {
 		data, err := filesource.ReadTestFile(filePath)
 		if err != nil {
-			ginkgo.Fail(fmt.Sprintf("fatal error looking for test file %s: %s", filePath, err), 1)
+			e2elog.Fail(fmt.Sprintf("fatal error looking for test file %s: %s", filePath, err), 1)
 		}
 		if data != nil {
 			return true
diff --git a/test/e2e/network/dns_configmap.go b/test/e2e/network/dns_configmap.go
index 37e072cd3d2..ba3ce501981 100644
--- a/test/e2e/network/dns_configmap.go
+++ b/test/e2e/network/dns_configmap.go
@@ -26,6 +26,7 @@ import (
 	e2eservice "k8s.io/kubernetes/test/e2e/framework/service"
 
 	"github.com/onsi/ginkgo"
+	e2elog "k8s.io/kubernetes/test/e2e/framework/log"
 )
 
 type dnsFederationsConfigMapTest struct {
@@ -408,12 +409,12 @@ func (t *dnsExternalNameTest) run(isIPv6 bool) {
 	serviceName := "dns-externalname-upstream-test"
 	externalNameService := e2eservice.CreateServiceSpec(serviceName, googleDNSHostname, false, nil)
 	if _, err := f.ClientSet.CoreV1().Services(f.Namespace.Name).Create(externalNameService); err != nil {
-		ginkgo.Fail(fmt.Sprintf("ginkgo.Failed when creating service: %v", err))
+		e2elog.Fail(fmt.Sprintf("ginkgo.Failed when creating service: %v", err))
 	}
 	serviceNameLocal := "dns-externalname-upstream-local"
 	externalNameServiceLocal := e2eservice.CreateServiceSpec(serviceNameLocal, fooHostname, false, nil)
 	if _, err := f.ClientSet.CoreV1().Services(f.Namespace.Name).Create(externalNameServiceLocal); err != nil {
-		ginkgo.Fail(fmt.Sprintf("ginkgo.Failed when creating service: %v", err))
+		e2elog.Fail(fmt.Sprintf("ginkgo.Failed when creating service: %v", err))
 	}
 	defer func() {
 		ginkgo.By("deleting the test externalName service")
diff --git a/test/e2e_kubeadm/e2e_kubeadm_suite_test.go b/test/e2e_kubeadm/e2e_kubeadm_suite_test.go
index 9a508138f94..6ebdc2cb145 100644
--- a/test/e2e_kubeadm/e2e_kubeadm_suite_test.go
+++ b/test/e2e_kubeadm/e2e_kubeadm_suite_test.go
@@ -31,6 +31,7 @@ import (
 	morereporters "github.com/onsi/ginkgo/reporters"
 	"k8s.io/kubernetes/test/e2e/framework"
 	e2econfig "k8s.io/kubernetes/test/e2e/framework/config"
+	e2elog "k8s.io/kubernetes/test/e2e/framework/log"
 )
 
 func init() {
@@ -48,7 +49,7 @@ func TestMain(m *testing.M) {
 }
 
 func TestE2E(t *testing.T) {
-	gomega.RegisterFailHandler(ginkgo.Fail)
+	gomega.RegisterFailHandler(e2elog.Fail)
 	reporters := []ginkgo.Reporter{}
 	reportDir := framework.TestContext.ReportDir
 	if reportDir != "" {
diff --git a/test/e2e_node/e2e_node_suite_test.go b/test/e2e_node/e2e_node_suite_test.go
index 84c1a6d9b94..ac07275b600 100644
--- a/test/e2e_node/e2e_node_suite_test.go
+++ b/test/e2e_node/e2e_node_suite_test.go
@@ -42,6 +42,7 @@ import (
 	commontest "k8s.io/kubernetes/test/e2e/common"
 	"k8s.io/kubernetes/test/e2e/framework"
 	e2econfig "k8s.io/kubernetes/test/e2e/framework/config"
+	e2elog "k8s.io/kubernetes/test/e2e/framework/log"
 	"k8s.io/kubernetes/test/e2e/framework/testfiles"
 	"k8s.io/kubernetes/test/e2e/generated"
 	"k8s.io/kubernetes/test/e2e_node/services"
@@ -131,7 +132,7 @@ func TestE2eNode(t *testing.T) {
 		return
 	}
 	// If run-services-mode is not specified, run test.
-	gomega.RegisterFailHandler(ginkgo.Fail)
+	gomega.RegisterFailHandler(e2elog.Fail)
 	reporters := []ginkgo.Reporter{}
 	reportDir := framework.TestContext.ReportDir
 	if reportDir != "" {