diff --git a/coordinator/src/main/scala/filodb.coordinator/queryplanner/HighAvailabilityPlanner.scala b/coordinator/src/main/scala/filodb.coordinator/queryplanner/HighAvailabilityPlanner.scala index 89fb6b82f0..2ec7334c1d 100644 --- a/coordinator/src/main/scala/filodb.coordinator/queryplanner/HighAvailabilityPlanner.scala +++ b/coordinator/src/main/scala/filodb.coordinator/queryplanner/HighAvailabilityPlanner.scala @@ -371,7 +371,12 @@ class HighAvailabilityPlanner(dsRef: DatasetRef, } else { false } - val path = shardMapper.coordForShard(i).path.toString + val actorRef = shardMapper.coordForShard(i) + val path = if (actorRef == akka.actor.ActorRef.noSender) { + "" + } else { + actorRef.path.toString + } shardInfoArray(i) = filodb.core.query.ShardInfo(isActive, path) } val localActiveShardMapper = ActiveShardMapper(shardInfoArray)