We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 6bfaf1a commit de1be7cCopy full SHA for de1be7c
pkg/frontend/clone.go
@@ -347,12 +347,15 @@ func handleCloneDatabase(
347
}
348
349
func tryToIncreaseTxnPhysicalTS(
350
- ctx context.Context,
351
- txnOp client.TxnOperator,
+ ctx context.Context, txnOp client.TxnOperator,
352
) (updatedPhysical int64, err error) {
353
354
curTxnPhysicalTS := txnOp.SnapshotTS().PhysicalTime
355
+ if ctx.Value(defines.TenantIDKey{}) == nil {
356
+ return curTxnPhysicalTS, nil
357
+ }
358
+
359
// a slight increase added to the physical to make sure
360
// the updated ts is greater than the old txn timestamp (physical + logic)
361
curTxnPhysicalTS += int64(time.Microsecond)
0 commit comments