save initial config instead of initial resource config (#3532)

This commit is contained in:
Alexey Tumanov
2018-12-13 20:39:42 -08:00
committed by Philipp Moritz
parent 84fae57ab5
commit 2455de78ce
2 changed files with 5 additions and 5 deletions
+3 -3
View File
@@ -55,7 +55,7 @@ NodeManager::NodeManager(boost::asio::io_service &io_service,
debug_dump_period_(config.debug_dump_period_ms),
temp_dir_(config.temp_dir),
object_manager_profile_timer_(io_service),
local_resources_(config.resource_config),
initial_config_(config),
local_available_resources_(config.resource_config),
worker_pool_(config.num_initial_workers, config.num_workers_per_process,
config.maximum_startup_concurrency, config.worker_commands),
@@ -332,7 +332,7 @@ void NodeManager::ClientAdded(const ClientTableDataT &client_data) {
if (client_id == gcs_client_->client_table().GetLocalClientId()) {
// We got a notification for ourselves, so we are connected to the GCS now.
// Save this NodeManager's resource information in the cluster resource map.
cluster_resource_map_[client_id] = local_resources_;
cluster_resource_map_[client_id] = initial_config_.resource_config;
return;
}
@@ -1778,7 +1778,7 @@ std::string NodeManager::DebugString() const {
std::stringstream result;
uint64_t now_ms = current_time_ms();
result << "NodeManager:";
result << "\nLocalResources: " << local_resources_.DebugString();
result << "\nInitialConfigResources: " << initial_config_.resource_config.ToString();
result << "\nClusterResources:";
for (auto &pair : cluster_resource_map_) {
result << "\n" << pair.first.hex() << ": " << pair.second.DebugString();
+2 -2
View File
@@ -389,8 +389,8 @@ class NodeManager {
uint64_t last_heartbeat_at_ms_;
/// The time that the last debug string was logged to the console.
uint64_t last_debug_dump_at_ms_;
/// The resources local to this node.
const SchedulingResources local_resources_;
/// Initial node manager configuration.
const NodeManagerConfig initial_config_;
/// The resources (and specific resource IDs) that are currently available.
ResourceIdSet local_available_resources_;
std::unordered_map<ClientID, SchedulingResources> cluster_resource_map_;