diff --git a/skywalking-storage-center/skywalking-storage/src/test/java/StorageThread.java b/skywalking-storage-center/skywalking-storage/src/test/java/StorageThread.java index 30e0614cc..6cc2ce705 100644 --- a/skywalking-storage-center/skywalking-storage/src/test/java/StorageThread.java +++ b/skywalking-storage-center/skywalking-storage/src/test/java/StorageThread.java @@ -42,12 +42,12 @@ public class StorageThread extends Thread { client.sendACKSpan(ackSpanList); client.sendRequestSpan(requestSpanList); cycle = 0; - } else { - requestSpanList[cycle] = requestSpan; - ackSpanList[cycle] = ackSpan; - cycle++; } + requestSpanList[cycle] = requestSpan; + ackSpanList[cycle] = ackSpan; + cycle++; + if (i % 10_000 == 0) { System.out.println(i + " " + value); }