diff --git a/client.go b/client.go index a259b14..804a287 100644 --- 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 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 {