diff --git a/e2e/cephfs_helper.go b/e2e/cephfs_helper.go
index 7c6c941bb..3b4c5630d 100644
--- a/e2e/cephfs_helper.go
+++ b/e2e/cephfs_helper.go
@@ -75,7 +75,7 @@ func createCephfsStorageClass(
 	sc.Parameters["csi.storage.k8s.io/node-stage-secret-name"] = cephFSNodePluginSecretName
 
 	if enablePool {
-		sc.Parameters["pool"] = "myfs-data0"
+		sc.Parameters["pool"] = "myfs-replicated"
 	}
 
 	// overload any parameters that were passed
diff --git a/e2e/rbd_helper.go b/e2e/rbd_helper.go
index 95184a509..b3730cb30 100644
--- a/e2e/rbd_helper.go
+++ b/e2e/rbd_helper.go
@@ -695,12 +695,12 @@ func deletePool(name string, cephFS bool, f *framework.Framework) error {
 		// ceph fs rm myfs --yes-i-really-mean-it
 		// ceph osd pool delete myfs-metadata myfs-metadata
 		// --yes-i-really-mean-it
-		// ceph osd pool delete myfs-data0 myfs-data0
+		// ceph osd pool delete myfs-replicated myfs-replicated
 		// --yes-i-really-mean-it
 		cmds = append(cmds, fmt.Sprintf("ceph fs fail %s", name),
 			fmt.Sprintf("ceph fs rm %s --yes-i-really-mean-it", name),
 			fmt.Sprintf("ceph osd pool delete %s-metadata %s-metadata --yes-i-really-really-mean-it", name, name),
-			fmt.Sprintf("ceph osd pool delete %s-data0 %s-data0 --yes-i-really-really-mean-it", name, name))
+			fmt.Sprintf("ceph osd pool delete %s-replicated %s-replicated --yes-i-really-really-mean-it", name, name))
 	} else {
 		// ceph osd pool delete replicapool replicapool
 		// --yes-i-really-mean-it