diff --git a/reward_index/src/indexer.rs b/reward_index/src/indexer.rs
index 2c80082b7..71b76cffb 100644
--- a/reward_index/src/indexer.rs
+++ b/reward_index/src/indexer.rs
@@ -65,7 +65,8 @@ impl Indexer {
                     return Ok(());
             }
             msg = receiver.recv() => if let Some(file_info_stream) = msg {
-                    tracing::info!("Processing reward file {}", file_info_stream.file_info.key);
+                let key = file_info_stream.file_info.key.clone();
+                    tracing::info!("Processing reward file {}", key);
                     let mut txn = self.pool.begin().await?;
                     let mut stream = file_info_stream.into_stream(&mut txn).await?;
 
@@ -77,6 +78,7 @@ impl Indexer {
                     }
 
                     txn.commit().await?;
+                    tracing::info!("Completed processing reward file {}", key);
                 }
             }
         }
@@ -108,7 +110,7 @@ impl Indexer {
         for (reward_key, amount) in hotspot_rewards {
             reward_index::insert(
                 &mut *txn,
-                &reward_key.key,
+                reward_key.key,
                 amount,
                 reward_key.reward_type,
                 &manifest_time,
diff --git a/reward_index/src/reward_index.rs b/reward_index/src/reward_index.rs
index bf6fd9bb0..c25ceff30 100644
--- a/reward_index/src/reward_index.rs
+++ b/reward_index/src/reward_index.rs
@@ -3,7 +3,7 @@ use chrono::{DateTime, Utc};
 
 pub async fn insert<'c, E>(
     executor: E,
-    address: &String,
+    address: String,
     amount: u64,
     reward_type: RewardType,
     timestamp: &DateTime<Utc>,