fix WriteTimestampEstimate ydb-platform#2

nshestakov · nshestakov · commit 11a9dba6b336 · 2024-12-11T08:53:58.000Z
diff --git a/ydb/core/persqueue/partition.cpp b/ydb/core/persqueue/partition.cpp
@@ -301,7 +301,7 @@ TInstant TPartition::GetWriteTimestampEstimate(ui64 lagSize) const {
         return WriteTimestampEstimate;
     }
 
-    return TAppData::TimeProvider->Now();
+    return std::max(TAppData::TimeProvider->Now(), WriteTimestampEstimate);
 }
 
 ui64 TPartition::ImportantClientsMinOffset() const {

Original file line number	Diff line number	Diff line change
`@@ -301,7 +301,7 @@ TInstant TPartition::GetWriteTimestampEstimate(ui64 lagSize) const {`
`301`	`301`	`return WriteTimestampEstimate;`
`302`	`302`	`}`
`303`	`303`
`304`		`- return TAppData::TimeProvider->Now();`
	`304`	`+ return std::max(TAppData::TimeProvider->Now(), WriteTimestampEstimate);`
`305`	`305`	`}`
`306`	`306`
`307`	`307`	`ui64 TPartition::ImportantClientsMinOffset() const {`