diff --git a/java/google/registry/tools/sql/registrar_account_data_view.sql b/java/google/registry/tools/sql/registrar_account_data_view.sql
index d8a58fa4f..7b8cc19c2 100644
--- a/java/google/registry/tools/sql/registrar_account_data_view.sql
+++ b/java/google/registry/tools/sql/registrar_account_data_view.sql
@@ -34,7 +34,7 @@ FROM (
     billingAccountMap.accountId,
     ROW_NUMBER() OVER (PARTITION BY registrarId) AS pos
   FROM
-    FLATTEN([latest_snapshot.Registrar], billingAccountMap.accountId)) AS I
+    FLATTEN([%SOURCE_DATASET%.Registrar], billingAccountMap.accountId)) AS I
 JOIN (
   SELECT
     __key__.name AS registrarId,