From f88641370566da6533fd2161ddecfc399757d720 Mon Sep 17 00:00:00 2001 From: Michael Marshall Date: Mon, 6 Feb 2023 12:50:34 -0600 Subject: [PATCH] Revert "modify check waitingForPingResponse with volatile (#12615)" This reverts commit 62e2547bea445c4f67935a57f59886757facbd2d. --- .../java/org/apache/pulsar/common/protocol/PulsarHandler.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pulsar-common/src/main/java/org/apache/pulsar/common/protocol/PulsarHandler.java b/pulsar-common/src/main/java/org/apache/pulsar/common/protocol/PulsarHandler.java index 7a783d89c3f0f..b28f7a6028084 100644 --- a/pulsar-common/src/main/java/org/apache/pulsar/common/protocol/PulsarHandler.java +++ b/pulsar-common/src/main/java/org/apache/pulsar/common/protocol/PulsarHandler.java @@ -40,7 +40,7 @@ public abstract class PulsarHandler extends PulsarDecoder { protected SocketAddress remoteAddress; private int remoteEndpointProtocolVersion = ProtocolVersion.v0.getValue(); private final long keepAliveIntervalSeconds; - private volatile boolean waitingForPingResponse = false; + private boolean waitingForPingResponse = false; private ScheduledFuture keepAliveTask; public int getRemoteEndpointProtocolVersion() {