diff --git a/skywalking-network/src/main/java/com/a/eye/skywalking/network/listener/client/StorageClientListener.java b/skywalking-network/src/main/java/com/a/eye/skywalking/network/listener/client/StorageClientListener.java index 469e043b1..964ff8c96 100644 --- a/skywalking-network/src/main/java/com/a/eye/skywalking/network/listener/client/StorageClientListener.java +++ b/skywalking-network/src/main/java/com/a/eye/skywalking/network/listener/client/StorageClientListener.java @@ -1,7 +1,5 @@ package com.a.eye.skywalking.network.listener.client; -import com.a.eye.skywalking.network.grpc.SendResult; - /** * Created by wusheng on 2016/11/27. */ diff --git a/skywalking-sniffer/skywalking-api/src/main/java/com/a/eye/skywalking/client/Agent2RoutingClient.java b/skywalking-sniffer/skywalking-api/src/main/java/com/a/eye/skywalking/client/Agent2RoutingClient.java index fdb02d8d0..093119a7c 100644 --- a/skywalking-sniffer/skywalking-api/src/main/java/com/a/eye/skywalking/client/Agent2RoutingClient.java +++ b/skywalking-sniffer/skywalking-api/src/main/java/com/a/eye/skywalking/client/Agent2RoutingClient.java @@ -91,7 +91,11 @@ public class Agent2RoutingClient extends Thread { spanStorageClient.sendACKSpan(ackData); while (!listener.isBatchFinished()) { - LockSupport.parkNanos(1); + try { + Thread.sleep(10L); + } catch (InterruptedException e) { + + } } } else { try { diff --git a/skywalking-storage-center/skywalking-routing/src/main/java/com/a/eye/skywalking/routing/disruptor/AbstractRouteSpanEventHandler.java b/skywalking-storage-center/skywalking-routing/src/main/java/com/a/eye/skywalking/routing/disruptor/AbstractRouteSpanEventHandler.java index 43cf46a68..7eb776c12 100644 --- a/skywalking-storage-center/skywalking-routing/src/main/java/com/a/eye/skywalking/routing/disruptor/AbstractRouteSpanEventHandler.java +++ b/skywalking-storage-center/skywalking-routing/src/main/java/com/a/eye/skywalking/routing/disruptor/AbstractRouteSpanEventHandler.java @@ -34,6 +34,7 @@ public abstract class AbstractRouteSpanEventHandler implements EventHandler