From 83d5265bd0a621dc0234a379df1a043954b2de4a Mon Sep 17 00:00:00 2001
From: William Chong <me@williamchong.cloud>
Date: Sun, 6 Mar 2022 03:11:45 +0800
Subject: [PATCH] Fix invalid table name on fork recovery

---
 src/database/sync.ts | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/database/sync.ts b/src/database/sync.ts
index d478a04..f0eb47b 100644
--- a/src/database/sync.ts
+++ b/src/database/sync.ts
@@ -89,7 +89,7 @@ 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
+       FROM ${KEYSPACE}.block_height_to_hash
        WHERE block_height > ${blockQueryResult.rows[0].height.toString()}
        ALLOW FILTERING`,
       [],