Skip to content

Commit eb3572d

Browse files
committed
nits
1 parent 28558e9 commit eb3572d

File tree

1 file changed

+2
-2
lines changed
  • pkg/stanza/operator/input/windows

1 file changed

+2
-2
lines changed

pkg/stanza/operator/input/windows/input.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -201,9 +201,9 @@ func (i *Input) read(ctx context.Context) {
201201
events, actualMaxReads, err := i.subscription.Read(i.currentMaxReads)
202202

203203
// Update the current max reads if it changed
204-
if actualMaxReads < i.currentMaxReads {
204+
if err == nil && actualMaxReads < i.currentMaxReads {
205205
i.currentMaxReads = actualMaxReads
206-
i.Logger().Debug("Encountered RPC_S_INVALID_BOUND, reducing batch size", zap.Int("current batch size", i.currentMaxReads), zap.Int("original batch size", i.maxReads))
206+
i.Logger().Debug("Encountered RPC_S_INVALID_BOUND, reduced batch size", zap.Int("current_batch_size", i.currentMaxReads), zap.Int("original_batch_size", i.maxReads))
207207
}
208208

209209
if err != nil {

0 commit comments

Comments
 (0)