diff options
| author | Oleg Doronin <dorooleg@yandex.ru> | 2024-02-01 19:00:19 +0300 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2024-02-01 19:00:19 +0300 |
| commit | 6673bedbbd326f22a0e39bea7c9882d1b51a64a6 (patch) | |
| tree | f675c240b7d2963feb71c62830320f8fd46b9d62 | |
| parent | 1088cdc6fa60c5e9dc6de9cdd1454a7f838fd25a (diff) | |
| download | ydb-6673bedbbd326f22a0e39bea7c9882d1b51a64a6.tar.gz | |
random shuffle has been fixed (#1499)
| -rw-r--r-- | ydb/core/fq/libs/control_plane_storage/internal/task_get.cpp | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/ydb/core/fq/libs/control_plane_storage/internal/task_get.cpp b/ydb/core/fq/libs/control_plane_storage/internal/task_get.cpp index 44127db0165..6bbc40224f5 100644 --- a/ydb/core/fq/libs/control_plane_storage/internal/task_get.cpp +++ b/ydb/core/fq/libs/control_plane_storage/internal/task_get.cpp @@ -338,7 +338,7 @@ void TYdbControlPlaneStorageActor::Handle(TEvControlPlaneStorage::TEvGetTaskRequ << (taskInternal.ShouldAbortTask ? " ABORTED" : "")); } - std::shuffle(tasks.begin(), tasks.end(), std::default_random_engine()); + std::shuffle(tasks.begin(), tasks.end(), std::default_random_engine(TInstant::Now().MicroSeconds())); const size_t numTasks = (std::min(tasks.size(), tasksBatchSize) + numTasksProportion - 1) / numTasksProportion; for (size_t i = 0; i < numTasks; ++i) { |