diff --git a/stackalytics/processor/runtime_storage.py b/stackalytics/processor/runtime_storage.py
index bc65e9e93..4c8474709 100644
--- a/stackalytics/processor/runtime_storage.py
+++ b/stackalytics/processor/runtime_storage.py
@@ -88,6 +88,7 @@ class MemcachedStorage(RuntimeStorage):
                 # insert record
                 record_id = self._get_record_count()
                 record['record_id'] = record_id
+                self.record_index[record['primary_key']] = record_id
                 LOG.debug('Insert new record %s' % record)
                 self.memcached.set(self._get_record_name(record_id), record)
                 self._set_record_count(record_id + 1)