diff --git a/frontend/src/routes/[conf]/[name]/observability/distributions/+page.ts b/frontend/src/routes/[conf]/[name]/observability/distributions/+page.ts
index 3082ed3739..822d3a5fa5 100644
--- a/frontend/src/routes/[conf]/[name]/observability/distributions/+page.ts
+++ b/frontend/src/routes/[conf]/[name]/observability/distributions/+page.ts
@@ -4,7 +4,7 @@ export const load = async ({ parent, fetch }) => {
 	const { conf, joinDrift, dateRange } = await parent();
 	const api = new Api({ fetch });
 
-	const confName = conf?.metaData?.name?.replace('/', '.') ?? 'Unknown';
+	const confName = conf?.metaData?.name ?? 'Unknown';
 	const columnNames = joinDrift?.driftSeries.map((ds) => ds.key?.column ?? 'Unknown') ?? [];
 
 	// Fetch percentile data for each column
diff --git a/frontend/src/routes/[conf]/[name]/observability/drift/+page.svelte b/frontend/src/routes/[conf]/[name]/observability/drift/+page.svelte
index c5804c12b3..548d2bac0e 100644
--- a/frontend/src/routes/[conf]/[name]/observability/drift/+page.svelte
+++ b/frontend/src/routes/[conf]/[name]/observability/drift/+page.svelte
@@ -87,7 +87,7 @@
 
 		if (seriesPoint) {
 			try {
-				const joinName = data.conf?.metaData?.name?.replace('/', '.') ?? 'Unknown';
+				const joinName = data.conf?.metaData?.name ?? 'Unknown';
 				const columnName = seriesPoint.series.key.toString();
 
 				// TODO: Add loading and error states
diff --git a/hub/src/main/scala/ai/chronon/hub/handlers/DriftHandler.scala b/hub/src/main/scala/ai/chronon/hub/handlers/DriftHandler.scala
index 488c1cab2f..72b9c510bb 100644
--- a/hub/src/main/scala/ai/chronon/hub/handlers/DriftHandler.scala
+++ b/hub/src/main/scala/ai/chronon/hub/handlers/DriftHandler.scala
@@ -35,11 +35,10 @@ class DriftHandler(driftStore: DriftStore) {
     }
 
     val window = new Window(offsetDuration.toMinutes.toInt, TimeUnit.MINUTES)
-    val joinPath = req.getName.replaceFirst("\\.", "/")
-    logger.debug(s"Querying drift store with window: $window, joinPath: $joinPath")
+    logger.debug(s"Querying drift store with window: $window, name: $req.getName")
 
     driftStore.getDriftSeries(
-      joinPath,
+      req.getName,
       req.getAlgorithm,
       window,
       req.getStartTs,
@@ -82,11 +81,10 @@ class DriftHandler(driftStore: DriftStore) {
   def getColumnSummary(req: JoinSummaryRequest): TileSummarySeries = {
     logger.debug(s"Processing summary request for join: ${req.getName}, column: ${req.getColumnName}")
 
-    val joinPath = req.getName.replaceFirst("\\.", "/")
-    logger.debug(s"Querying summary store with joinPath: $joinPath")
+    logger.debug(s"Querying summary store with name: $req.getName")
 
     driftStore.getSummarySeries(
-      joinPath,
+      req.getName,
       req.getStartTs,
       req.getEndTs,
       Some(req.getColumnName)
diff --git a/spark/src/main/scala/ai/chronon/spark/scripts/ObservabilityDemo.scala b/spark/src/main/scala/ai/chronon/spark/scripts/ObservabilityDemo.scala
index f22e6ae1b1..76db009097 100644
--- a/spark/src/main/scala/ai/chronon/spark/scripts/ObservabilityDemo.scala
+++ b/spark/src/main/scala/ai/chronon/spark/scripts/ObservabilityDemo.scala
@@ -155,13 +155,12 @@ object ObservabilityDemo {
     val name = "dim_user_account_type"
     val window = new Window(10, ai.chronon.api.TimeUnit.HOURS)
 
-    val joinPath = joinName.replaceFirst("\\.", "/")
     logger.info("Looking up current summary series")
-    val maybeCurrentSummarySeries = driftStore.getSummarySeries(joinPath, startTs, endTs, Some(name)).get
+    val maybeCurrentSummarySeries = driftStore.getSummarySeries(joinName, startTs, endTs, Some(name)).get
     val currentSummarySeries = Await.result(maybeCurrentSummarySeries, Duration.create(10, TimeUnit.SECONDS))
     logger.info("Now looking up baseline summary series")
     val maybeBaselineSummarySeries =
-      driftStore.getSummarySeries(joinPath, startTs - window.millis, endTs - window.millis, Some(name))
+      driftStore.getSummarySeries(joinName, startTs - window.millis, endTs - window.millis, Some(name))
     val baselineSummarySeries = Await.result(maybeBaselineSummarySeries.get, Duration.create(10, TimeUnit.SECONDS))
 
     logger.info(s"Current summary series: $currentSummarySeries")