From 1fe42c88c3777d89bfcb1d41bbcb07926ab065d7 Mon Sep 17 00:00:00 2001 From: cyan317 <120398799+cindyyan317@users.noreply.github.com> Date: Fri, 12 Apr 2024 15:06:51 +0100 Subject: [PATCH] Fix deletion script (#1357) Because the slice has not done deep clone. All the _Data_ in _deleteInfo_ will eventually refer to the last item in partition. Please refer to "reuse slice session" from: https://pkg.go.dev/github.com/gocql/gocql#hdr-Reusing_slices --- tools/cassandra_delete_range/main.go | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/tools/cassandra_delete_range/main.go b/tools/cassandra_delete_range/main.go index 7a191d60..ef4ebc10 100644 --- a/tools/cassandra_delete_range/main.go +++ b/tools/cassandra_delete_range/main.go @@ -484,8 +484,6 @@ func prepareDeleteQueries(cluster *gocql.ClusterConfig, fromLedgerIdx uint64, qu var pageState []byte var rowsRetrieved uint64 - var key []byte - var seq uint64 for { iter := preparedQuery.PageSize(*clusterPageSize).PageState(pageState).Iter() @@ -493,6 +491,9 @@ func prepareDeleteQueries(cluster *gocql.ClusterConfig, fromLedgerIdx uint64, qu scanner := iter.Scanner() for scanner.Next() { + var key []byte + var seq uint64 + err = scanner.Scan(&key, &seq) if err == nil { rowsRetrieved++