luciano/vmware-go-kcl-v2
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Reduce log noise from found shards in worker event loop (#66)

Browse source 
Signed-off-by: Kev Burns <kevburnsjr@gmail.com>
This commit is contained in:
Kevin Burns 2020-01-22 03:26:22 -08:00 committed by Tao Jiang
parent f1935bc0ff
commit 8f0d7bc8d8
1 changed files with 5 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
clientlibrary/worker/worker.go
View file

@ -238,6 +238,7 @@ func (w *Worker) newShardConsumer(shard *par.ShardStatus) *ShardConsumer {
func (w *Worker) eventLoop() { func (w *Worker) eventLoop() {
log := w.kclConfig.Logger log := w.kclConfig.Logger
var foundShards int
for { for {
// Add [-50%, +50%] random jitter to ShardSyncIntervalMillis. When multiple workers // Add [-50%, +50%] random jitter to ShardSyncIntervalMillis. When multiple workers
// starts at the same time, this decreases the probability of them calling // starts at the same time, this decreases the probability of them calling
@ -252,7 +253,10 @@ func (w *Worker) eventLoop() {
continue continue
} }
log.Infof("Found %d shards", len(w.shardStatus)) if foundShards == 0 || foundShards != len(w.shardStatus) {
foundShards = len(w.shardStatus)
log.Infof("Found %d shards", foundShards)
}
// Count the number of leases hold by this worker excluding the processed shard // Count the number of leases hold by this worker excluding the processed shard
counter := 0 counter := 0