diff --git a/firestore-bigquery-export/firestore-bigquery-change-tracker/src/bigquery/initializeLatestView.ts b/firestore-bigquery-export/firestore-bigquery-change-tracker/src/bigquery/initializeLatestView.ts
index 8e017397b..2966962f6 100644
--- a/firestore-bigquery-export/firestore-bigquery-change-tracker/src/bigquery/initializeLatestView.ts
+++ b/firestore-bigquery-export/firestore-bigquery-change-tracker/src/bigquery/initializeLatestView.ts
@@ -87,6 +87,7 @@ export async function initializeLatestView({
       metadata.view = latestConsistentSnapshotView({
         datasetId: config.datasetId,
         tableName: rawChangeLogTableName,
+        bqProjectId: bq.projectId,
         schema,
         useLegacyQuery: !config.useNewSnapshotQuerySyntax,
       });
diff --git a/firestore-bigquery-export/scripts/import/src/worker.ts b/firestore-bigquery-export/scripts/import/src/worker.ts
index 23e9a9065..19c80c6d1 100644
--- a/firestore-bigquery-export/scripts/import/src/worker.ts
+++ b/firestore-bigquery-export/scripts/import/src/worker.ts
@@ -26,6 +26,7 @@ async function processDocuments(
     tableId,
     datasetId,
     datasetLocation,
+    bigQueryProjectId,
     batchSize,
     failedBatchOutput,
   } = config;
@@ -71,6 +72,7 @@ async function processDocuments(
     datasetId,
     datasetLocation,
     wildcardIds: true,
+    bqProjectId: bigQueryProjectId,
     skipInit: true,
     useNewSnapshotQuerySyntax: config.useNewSnapshotQuerySyntax,
     transformFunction: config.transformFunctionUrl,