Initialize last_node_activity for all nodes

ianton-ru · ianton-ru · commit eb9bfbeccd1a · 2025-11-28T16:39:08.000+01:00
diff --git a/src/Storages/ObjectStorage/StorageObjectStorageStableTaskDistributor.cpp b/src/Storages/ObjectStorage/StorageObjectStorageStableTaskDistributor.cpp
@@ -24,9 +24,13 @@ StorageObjectStorageStableTaskDistributor::StorageObjectStorageStableTaskDistrib
     , lock_object_storage_task_distribution_us(lock_object_storage_task_distribution_ms_ * 1000)
     , iterator_exhausted(false)
 {
+    Poco::Timestamp now;
     size_t nodes = ids_of_nodes.size();
     for (size_t i = 0; i < nodes; ++i)
+    {
         replica_to_files_to_be_processed[i] = std::list<ObjectInfoPtr>{};
+        last_node_activity[i] = now;
+    }
 }
 
 ObjectInfoPtr StorageObjectStorageStableTaskDistributor::getNextTask(size_t number_of_current_replica)

Original file line number	Diff line number	Diff line change
`@@ -24,9 +24,13 @@ StorageObjectStorageStableTaskDistributor::StorageObjectStorageStableTaskDistrib`
`24`	`24`	`, lock_object_storage_task_distribution_us(lock_object_storage_task_distribution_ms_ * 1000)`
`25`	`25`	`, iterator_exhausted(false)`
`26`	`26`	`{`
	`27`	`+ Poco::Timestamp now;`
`27`	`28`	`size_t nodes = ids_of_nodes.size();`
`28`	`29`	`for (size_t i = 0; i < nodes; ++i)`
	`30`	`+ {`
`29`	`31`	`replica_to_files_to_be_processed[i] = std::list<ObjectInfoPtr>{};`
	`32`	`+ last_node_activity[i] = now;`
	`33`	`+ }`
`30`	`34`	`}`
`31`	`35`
`32`	`36`	`ObjectInfoPtr StorageObjectStorageStableTaskDistributor::getNextTask(size_t number_of_current_replica)`