From eff54f49a6fbbab4a48a4c5182d82b8e0783fb7a Mon Sep 17 00:00:00 2001 From: Todd Gruben Date: Tue, 8 Mar 2022 17:26:25 -0600 Subject: [PATCH] qcx finish/reset --- executor.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/executor.go b/executor.go index f12c957d3..e3f52d806 100644 --- a/executor.go +++ b/executor.go @@ -8303,6 +8303,8 @@ func (e *executor) executeDeleteRecordFromShard(ctx context.Context, qcx *Qcx, i return } + qcx.Finish() // have to release the tx in order for a snapshot to be able to occur + qcx.Reset() return DeleteRowsWithFlow(ctx, src, idx, shard, true) }