Skip to content

Commit

Permalink
Fixed build error
Browse files Browse the repository at this point in the history
  • Loading branch information
GrigoriyPA committed Nov 21, 2024
1 parent 8d54720 commit 74e30f2
Showing 1 changed file with 4 additions and 1 deletion.
5 changes: 4 additions & 1 deletion ydb/core/fq/libs/row_dispatcher/coordinator.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -280,8 +280,11 @@ std::optional<TActorId> TActorCoordinator::GetAndUpdateLocation(const TPartition
return std::nullopt;
}

auto rowDispatcherIt = RowDispatchers.find(bestLocation);
Y_ENSURE(rowDispatcherIt != RowDispatchers.end(), "Invalid best location");

PartitionLocations[key] = bestLocation;
RowDispatchers[bestLocation].Locations.insert(key);
rowDispatcherIt->second.Locations.insert(key);
topicPartitionsCount[bestLocation.NodeId()]++;
return bestLocation;
}
Expand Down

0 comments on commit 74e30f2

Please sign in to comment.