From c2237575ce53f5b94e0b1fca4f4f0a87f15383e2 Mon Sep 17 00:00:00 2001 From: wusheng Date: Wed, 23 Nov 2016 21:32:40 +0800 Subject: [PATCH] fix --- .../skywalking-storage/src/test/java/StorageThread.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) 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); }