diff options
| author | alexnick <alexnick@yandex-team.ru> | 2022-05-13 23:04:49 +0300 |
|---|---|---|
| committer | alexnick <alexnick@yandex-team.ru> | 2022-05-13 23:04:49 +0300 |
| commit | 30335423628bca3c7c1a2d2005e44cc6c70b7c0b (patch) | |
| tree | 1178d10beb5c2913df9b544e35c890b489595e71 | |
| parent | 5a7eed6354c76f03e2ca2b25ccbbebc3ca4bd79c (diff) | |
| download | ydb-30335423628bca3c7c1a2d2005e44cc6c70b7c0b.tar.gz | |
mirror write timestamp LOGBROKER-7067
ref:7a09891661266de66bbf6c613f964d233aaee723
| -rw-r--r-- | ydb/services/lib/actors/pq_schema_actor.cpp | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/ydb/services/lib/actors/pq_schema_actor.cpp b/ydb/services/lib/actors/pq_schema_actor.cpp index 11f106cbca..cbd4c00bf8 100644 --- a/ydb/services/lib/actors/pq_schema_actor.cpp +++ b/ydb/services/lib/actors/pq_schema_actor.cpp @@ -407,6 +407,9 @@ namespace NKikimr::NGRpcProxy::V1 { } if (settings.has_remote_mirror_rule()) { auto mirrorFrom = partConfig->MutableMirrorFrom(); + if (!local) { + mirrorFrom->SetSyncWriteTime(true); + } { TString endpoint = settings.remote_mirror_rule().endpoint(); if (endpoint.StartsWith(GRPCS_ENDPOINT_PREFIX)) { |