diff --git a/core/src/main/clojure/xtdb/indexer/live_index.clj b/core/src/main/clojure/xtdb/indexer/live_index.clj
index d5a8affaad..ed67bc1767 100644
--- a/core/src/main/clojure/xtdb/indexer/live_index.clj
+++ b/core/src/main/clojure/xtdb/indexer/live_index.clj
@@ -145,7 +145,7 @@
           (locking this-table
             (let [wm-live-rel (open-wm-live-rel live-rel retain?)
                   col-types (live-rel->col-types wm-live-rel)
-                  wm-live-trie (.compactLogs ^LiveHashTrie @!transient-trie)]
+                  wm-live-trie @!transient-trie]
               (reify ILiveTableWatermark
                 (columnTypes [_] col-types)
                 (liveRelation [_] wm-live-rel)
@@ -177,7 +177,7 @@
     (locking this
       (let [wm-live-rel (open-wm-live-rel live-rel retain?)
             col-types (live-rel->col-types wm-live-rel)
-            wm-live-trie (.compactLogs live-trie)]
+            wm-live-trie live-trie]
 
         (reify ILiveTableWatermark
           (columnTypes [_] col-types)
diff --git a/core/src/main/clojure/xtdb/operator/scan.clj b/core/src/main/clojure/xtdb/operator/scan.clj
index 0be23de3e8..375cd09488 100644
--- a/core/src/main/clojure/xtdb/operator/scan.clj
+++ b/core/src/main/clojure/xtdb/operator/scan.clj
@@ -508,7 +508,7 @@
                   (.load loader record-batch)
                   (.add trie-roots root)))))
           (let [hash-tries (cond-> (mapv #(ArrowHashTrie/from %) trie-roots)
-                             live-table-wm (conj (.liveTrie live-table-wm)))]
+                             live-table-wm (conj (.compactLogs (.liveTrie live-table-wm))))]
 
             {:arrow-leaves (mapv (fn [{:keys [leaf-buf leaf-root]}]
                                    (reify AutoCloseable