Skip to content

Commit 7e0e431

Browse files
committed
Fix the in method restoreInvariants of AbstractRpcLogSender.
1 parent f77d065 commit 7e0e431

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)