From 56df288385fb836c4f29e2bed3e1bfcc176d3341 Mon Sep 17 00:00:00 2001 From: Jason Sung Date: Wed, 8 Jan 2025 10:29:46 -0800 Subject: [PATCH] set higher priority for renewal scans --- client.go | 1 + scanner.go | 2 +- 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/client.go b/client.go index a259b14..c1f869d 100644 --- a/client.go +++ b/client.go @@ -30,6 +30,7 @@ const ( defaultZkRoot = "/hbase" defaultZkTimeout = 30 * time.Second defaultEffectiveUser = "root" + defaultRenewScannerPriority = 25 ) // Client a regular HBase client diff --git a/scanner.go b/scanner.go index d1c445b..d37a89e 100644 --- a/scanner.go +++ b/scanner.go @@ -390,7 +390,7 @@ func (s *scanner) renew(ctx context.Context, startRow []byte) error { startRow, nil, hrpc.ScannerID(s.curRegionScannerID), - hrpc.Priority(s.rpc.Priority()), + hrpc.Priority(defaultRenewScannerPriority), hrpc.RenewalScan(), ) if err != nil {