Closed shanson7 closed 2 years ago
Describe the bug
In rare cases when a new series is created and persisted in a small window, it might still be in the index writeQueue. When the notifier attempts to use Get() it cannot find it and prints
Get()
kafka-cluster: failed to lookup metricDef
It seems that UnpartitionedMemoryIdx.Get needs to check the writeQueue.
Describe the bug
In rare cases when a new series is created and persisted in a small window, it might still be in the index writeQueue. When the notifier attempts to use
Get()
it cannot find it and printskafka-cluster: failed to lookup metricDef
It seems that UnpartitionedMemoryIdx.Get needs to check the writeQueue.