Skip to content

Commit

Permalink
add check in ingesterTracker to better handle multi-indexer setups
Browse files Browse the repository at this point in the history
  • Loading branch information
floren committed Oct 20, 2021
1 parent ab9276c commit b100da9
Showing 1 changed file with 5 additions and 1 deletion.
6 changes: 5 additions & 1 deletion utils/ingesterTracker.ank
Original file line number Diff line number Diff line change
Expand Up @@ -145,6 +145,10 @@ module PersistentIngesterTracker {
for idxName, igs in igstMap {
for ig in igs.Ingesters {
var igName = GetIngesterID(ig)
if _times[igName] == _now {
// we've already checked it (happens when there are multiple indexers)
continue
}
_times[igName] = _now
info, ok = _id[igName]
if !ok {
Expand All @@ -156,7 +160,7 @@ module PersistentIngesterTracker {
} else if info[`state`] != `ONLINE` {
info[`statechange`] = `ONLINE`
} else {
info[`statechange`] = `` //remove anyt state change that might have been there before
info[`statechange`] = `` //remove any state change that might have been there before
}
info[`state`] = `ONLINE`
_id[igName] = info
Expand Down

0 comments on commit b100da9

Please sign in to comment.