Skip to content

Commit

Permalink
set higher priority for renewal scans
Browse files Browse the repository at this point in the history
  • Loading branch information
gogochickenleg committed Jan 8, 2025
1 parent bed85a0 commit 56df288
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 1 deletion.
1 change: 1 addition & 0 deletions client.go
Original file line number Diff line number Diff line change
Expand Up @@ -30,6 +30,7 @@ const (
defaultZkRoot = "/hbase"
defaultZkTimeout = 30 * time.Second
defaultEffectiveUser = "root"
defaultRenewScannerPriority = 25
)

// Client a regular HBase client
Expand Down
2 changes: 1 addition & 1 deletion scanner.go
Original file line number Diff line number Diff line change
Expand Up @@ -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 {
Expand Down

0 comments on commit 56df288

Please sign in to comment.