Skip to content

Commit 20d3d5c

Browse files
Merge remote-tracking branch 'origin/dev-0.2.3-log-collector' into dev-0.2.3-log-collector
2 parents 1d0f314 + 12b85b8 commit 20d3d5c

File tree

1 file changed

+2
-1
lines changed
  • streamis-jobmanager/streamis-job-log/job-log-collector/streamis-job-log-collector-core/src/main/java/com/webank/wedatasphere/streamis/jobmanager/log/collector/sender

1 file changed

+2
-1
lines changed

streamis-jobmanager/streamis-job-log/job-log-collector/streamis-job-log-collector-core/src/main/java/com/webank/wedatasphere/streamis/jobmanager/log/collector/sender/AbstractRpcLogSender.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -435,7 +435,8 @@ private void restoreInvariants(int i, int take, boolean clearItems){
435435
this.count -= i;
436436
if (clearItems){
437437
int index = this.takeIndex;
438-
for (; i > 0; i --){
438+
int j = i;
439+
for (; j > 0; j --){
439440
this.items[index] = null;
440441
if (++index == items.length){
441442
index = 0;

0 commit comments

Comments
 (0)