set higher priority for renewal scans

tsuna · Jan 8, 2025 · 3551ca7 · 3551ca7
1 parent bed85a0
commit 3551ca7
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 6 deletions.
diff --git a/client.go b/client.go
@@ -25,11 +25,12 @@ import (
 )
 
 const (
-	defaultRPCQueueSize  = 100
-	defaultFlushInterval = 20 * time.Millisecond
-	defaultZkRoot        = "/hbase"
-	defaultZkTimeout     = 30 * time.Second
-	defaultEffectiveUser = "root"
+	defaultRPCQueueSize         = 100
+	defaultFlushInterval        = 20 * time.Millisecond
+	defaultZkRoot               = "/hbase"
+	defaultZkTimeout            = 30 * time.Second
+	defaultEffectiveUser        = "root"
+	defaultRenewScannerPriority = 25
 )
 
 // Client a regular HBase client

diff --git 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 {