diff --git a/client/src/main/java/com/alibaba/nacos/client/config/impl/ClientWorker.java b/client/src/main/java/com/alibaba/nacos/client/config/impl/ClientWorker.java index 6aac641cb..98ae4c467 100644 --- a/client/src/main/java/com/alibaba/nacos/client/config/impl/ClientWorker.java +++ b/client/src/main/java/com/alibaba/nacos/client/config/impl/ClientWorker.java @@ -344,8 +344,6 @@ public class ClientWorker { List params = Arrays.asList(Constants.PROBE_MODIFY_REQUEST, probeUpdateString); - // Take a custom timeout parameter to circumvent network errors caused by network latency - List headers = new ArrayList(2); headers.add("Long-Pulling-Timeout"); headers.add("" + timeout); @@ -560,6 +558,6 @@ public class ClientWorker { ConfigFilterChainManager configFilterChainManager; private boolean isHealthServer = true; private long timeout; - private volatile double currentLongingTaskCount = 0; + private double currentLongingTaskCount = 0; private int taskPenaltyTime; } diff --git a/config/src/main/java/com/alibaba/nacos/config/server/service/LongPollingService.java b/config/src/main/java/com/alibaba/nacos/config/server/service/LongPollingService.java index d9caa2c2c..ec8ae8fff 100755 --- a/config/src/main/java/com/alibaba/nacos/config/server/service/LongPollingService.java +++ b/config/src/main/java/com/alibaba/nacos/config/server/service/LongPollingService.java @@ -241,7 +241,6 @@ public class LongPollingService extends AbstractEventListener { // AsyncContext.setTimeout()的超时时间不准,所以只能自己控制 asyncContext.setTimeout(0L); - // I think there is a problem with the task delay setting here that could easily cause a client read timeout scheduler.execute( new ClientLongPolling(asyncContext, clientMd5Map, ip, probeRequestSize, timeout, appName, tag)); }