Skip to content

Commit 18e63b7

Browse files
AndreasHoltTheis-Mathiassen
authored andcommitted
fix(shard distributor): log invalid shard load
Signed-off-by: Andreas Holt <[email protected]> Signed-off-by: Theis Randeris Mathiassen <[email protected]>
1 parent 9d159e7 commit 18e63b7

File tree

1 file changed

+6
-0
lines changed
  • service/sharddistributor/store/etcd/executorstore

1 file changed

+6
-0
lines changed

service/sharddistributor/store/etcd/executorstore/etcdstore.go

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -183,6 +183,12 @@ func (s *executorStoreImpl) updateShardStatisticsFromHeartbeat(ctx context.Conte
183183

184184
load := report.ShardLoad
185185
if math.IsNaN(load) || math.IsInf(load, 0) {
186+
s.logger.Warn(
187+
"invalid shard load reported; skipping EWMA update",
188+
tag.ShardNamespace(namespace),
189+
tag.ShardExecutor(executorID),
190+
tag.ShardKey(shardID),
191+
)
186192
continue
187193
}
188194

0 commit comments

Comments
 (0)