Details
-
Bug
-
Resolution: Fixed
-
Major
-
7.1.0, 7.1.1, 7.1.2
-
Security Level: Public
-
Untriaged
-
1
-
Unknown
Description
In indexer::checkCatchupPendingForStream, indexer should check the keyspaceId for the stream that is passed through and not the stream of the index. Otherwise, the index.Defn.KeyspaceId(index.Stream) will fail and indexer will not start the MAINT_STREAM
func (idx *indexer) checkCatchupPendingForStream(streamId common.StreamId,
|
keyspaceId string) bool {
|
|
|
//catch is only possible for MAINT_STREAM
|
if streamId != common.MAINT_STREAM {
|
return false
|
}
|
|
|
//check if any index of the given keyspaceId is in the Stream
|
for _, index := range idx.indexInstMap {
|
|
|
if index.Defn.KeyspaceId(index.Stream) == keyspaceId && index.Stream == common.INIT_STREAM &&
|
index.State == common.INDEX_STATE_CATCHUP {
|
return true
|
}
|
}
|
|
|
return false
|
}
|