diff --git a/test/e2e-tests.sh b/test/e2e-tests.sh
index a0087ee23da..080b01bb6be 100755
--- a/test/e2e-tests.sh
+++ b/test/e2e-tests.sh
@@ -27,11 +27,7 @@
 
 source $(dirname $0)/../vendor/github.com/knative/test-infra/scripts/e2e-tests.sh
 
-# Using the most recent good release of eventing-sources to unblock tests. This
-# should be replaced with the commented line below when eventing-sources nightly
-# is known good again.
-readonly KNATIVE_EVENTING_SOURCES_RELEASE=https://knative-nightly.storage.googleapis.com/eventing-sources/previous/v20181205-fbac942/release.yaml
-#readonly KNATIVE_EVENTING_SOURCES_RELEASE=https://knative-nightly.storage.googleapis.com/eventing-sources/latest/release.yaml
+readonly KNATIVE_EVENTING_SOURCES_RELEASE=https://knative-nightly.storage.googleapis.com/eventing-sources/latest/release.yaml
 
 # Names of the Resources used in the tests.
 readonly E2E_TEST_NAMESPACE=e2etest
diff --git a/test/e2e/e2e.go b/test/e2e/e2e.go
index 62ba6f81ef3..a0bb80c6675 100644
--- a/test/e2e/e2e.go
+++ b/test/e2e/e2e.go
@@ -157,7 +157,7 @@ func CreateServiceAccountAndBinding(clients *test.Clients, name string, logger *
 	sa := &corev1.ServiceAccount{
 		ObjectMeta: metav1.ObjectMeta{
 			Name:      name,
-			Namespace: defaultNamespaceName,
+			Namespace: pkgTest.Flags.Namespace,
 		},
 	}
 	err := CreateServiceAccount(clients, sa, logger, cleaner)
@@ -172,7 +172,7 @@ func CreateServiceAccountAndBinding(clients *test.Clients, name string, logger *
 			{
 				Kind:      "ServiceAccount",
 				Name:      name,
-				Namespace: defaultNamespaceName,
+				Namespace: pkgTest.Flags.Namespace,
 			},
 		},
 		RoleRef: rbacv1.RoleRef{
diff --git a/test/e2e/k8s_events_test.go b/test/e2e/k8s_events_test.go
index f321f3071f4..0993356fa93 100644
--- a/test/e2e/k8s_events_test.go
+++ b/test/e2e/k8s_events_test.go
@@ -52,14 +52,14 @@ func TestKubernetesEvents(t *testing.T) {
 	}
 
 	logger.Infof("Creating Channel")
-	channel := test.Channel(channelName, defaultNamespaceName, test.ClusterChannelProvisioner(provisionerName))
+	channel := test.Channel(channelName, pkgTest.Flags.Namespace, test.ClusterChannelProvisioner(provisionerName))
 	err = CreateChannel(clients, channel, logger, cleaner)
 	if err != nil {
 		t.Fatalf("Failed to create Channel: %v", err)
 	}
 
 	logger.Infof("Creating EventSource")
-	k8sSource := test.KubernetesEventSource(eventSource, defaultNamespaceName, testNamespace, serviceAccount, test.ChannelRef(channelName))
+	k8sSource := test.KubernetesEventSource(eventSource, pkgTest.Flags.Namespace, testNamespace, serviceAccount, test.ChannelRef(channelName))
 	err = CreateKubernetesEventSource(clients, k8sSource, logger, cleaner)
 	if err != nil {
 		t.Fatalf("Failed to create KubernetesEventSource: %v", err)
@@ -74,7 +74,7 @@ func TestKubernetesEvents(t *testing.T) {
 	}
 
 	logger.Infof("Creating Subscription")
-	subscription := test.Subscription(subscriptionName, defaultNamespaceName, test.ChannelRef(channelName), test.SubscriberSpecForRoute(routeName), nil)
+	subscription := test.Subscription(subscriptionName, pkgTest.Flags.Namespace, test.ChannelRef(channelName), test.SubscriberSpecForRoute(routeName), nil)
 	err = CreateSubscription(clients, subscription, logger, cleaner)
 	if err != nil {
 		t.Fatalf("Failed to create Subscription: %v", err)