diff --git a/ksql-rest-app/src/main/java/io/confluent/ksql/rest/server/computation/CommandStore.java b/ksql-rest-app/src/main/java/io/confluent/ksql/rest/server/computation/CommandStore.java
index 906922558d82..ea0581d7050a 100644
--- a/ksql-rest-app/src/main/java/io/confluent/ksql/rest/server/computation/CommandStore.java
+++ b/ksql-rest-app/src/main/java/io/confluent/ksql/rest/server/computation/CommandStore.java
@@ -192,7 +192,6 @@ public List<QueuedCommand> getRestoreCommands() {
 
     log.debug("Reading prior command records");
 
-    final Map<CommandId, ConsumerRecord<CommandId, Command>> commands = Maps.newLinkedHashMap();
     ConsumerRecords<CommandId, Command> records =
         commandConsumer.poll(POLLING_TIMEOUT_FOR_COMMAND_TOPIC);
     while (!records.isEmpty()) {
@@ -209,7 +208,7 @@ public List<QueuedCommand> getRestoreCommands() {
       }
       records = commandConsumer.poll(POLLING_TIMEOUT_FOR_COMMAND_TOPIC);
     }
-    log.debug("Retrieved records:" + commands.size());
+    log.debug("Retrieved records:" + restoreCommands.size());
     return restoreCommands;
   }