remove unused map from command store getRestoreCommands (#2296)

confluentinc · Dec 20, 2018 · 82f83ae · 82f83ae
1 parent 27fa002
commit 82f83ae
Showing 1 changed file with 1 addition and 2 deletions.
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
@@ -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;
   }