Fix invalid table name on fork recovery

ArweaveTeam · Mar 5, 2022 · f6bcd36 · f6bcd36
1 parent 1d331e3
commit f6bcd36
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/src/database/sync.ts b/src/database/sync.ts
@@ -89,9 +89,8 @@ async function resolveFork(previousBlock: BlockType): Promise<void> {
     // eslint-disable-next-line @typescript-eslint/no-unused-vars
     const result = await cassandraClient.execute(
       `SELECT block_height,block_hash
-       FROM ${KEYSPACE}.block_height_by_block_hash
-       WHERE block_height > ${blockQueryResult.rows[0].height.toString()}
-       ALLOW FILTERING`,
+       FROM ${KEYSPACE}.block_height_to_hash
+       WHERE block_height > ${blockQueryResult.rows[0].height.toString()}`,
       [],
       { prepare: true }
     );