From a2f766d66d7a721c199cd2f116f750ebad63dfc3 Mon Sep 17 00:00:00 2001 From: Roger Ng Date: Tue, 13 Jan 2026 11:11:39 +0000 Subject: [PATCH] Stop reading unused `rootHash` in `consumeEntries` func --- storage/gcp/gcp.go | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/storage/gcp/gcp.go b/storage/gcp/gcp.go index e56f9845..e3a55a89 100644 --- a/storage/gcp/gcp.go +++ b/storage/gcp/gcp.go @@ -877,13 +877,12 @@ func (s *spannerCoordinator) consumeEntries(ctx context.Context, limit uint64, f didWork := false _, err := s.dbPool.ReadWriteTransaction(ctx, func(ctx context.Context, txn *spanner.ReadWriteTransaction) error { // Figure out which is the starting index of sequenced entries to start consuming from. - row, err := txn.ReadRowWithOptions(ctx, "IntCoord", spanner.Key{0}, []string{"seq", "rootHash"}, &spanner.ReadOptions{LockHint: spannerpb.ReadRequest_LOCK_HINT_EXCLUSIVE}) + row, err := txn.ReadRowWithOptions(ctx, "IntCoord", spanner.Key{0}, []string{"seq"}, &spanner.ReadOptions{LockHint: spannerpb.ReadRequest_LOCK_HINT_EXCLUSIVE}) if err != nil { return err } var fromSeq int64 // Spanner doesn't support uint64 - var rootHash []byte - if err := row.Columns(&fromSeq, &rootHash); err != nil { + if err := row.Columns(&fromSeq); err != nil { return fmt.Errorf("failed to read integration coordination info: %v", err) }