diff --git a/skywalking-network/src/main/java/com/a/eye/skywalking/network/grpc/client/SpanStorageClient.java b/skywalking-network/src/main/java/com/a/eye/skywalking/network/grpc/client/SpanStorageClient.java index 74731449e..5a6aa8eed 100644 --- a/skywalking-network/src/main/java/com/a/eye/skywalking/network/grpc/client/SpanStorageClient.java +++ b/skywalking-network/src/main/java/com/a/eye/skywalking/network/grpc/client/SpanStorageClient.java @@ -39,7 +39,7 @@ public class SpanStorageClient { } while (!((CallStreamObserver) requestSpanStreamObserver).isReady()) { try { - Thread.currentThread().sleep(1); + Thread.sleep(1); } catch (InterruptedException e) { throw new ConsumeSpanDataFailedException(e); } @@ -71,7 +71,7 @@ public class SpanStorageClient { } while (!((CallStreamObserver) ackSpanStreamObserver).isReady()) { try { - Thread.currentThread().sleep(1); + Thread.sleep(1); } catch (InterruptedException e) { throw new ConsumeSpanDataFailedException(e); }