You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pinot.apache.org by ja...@apache.org on 2021/10/01 22:48:21 UTC
[pinot] branch master updated: fix volatile stopped flag (#7508)
This is an automated email from the ASF dual-hosted git repository.
jackie pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pinot.git
The following commit(s) were added to refs/heads/master by this push:
new cccc1e3 fix volatile stopped flag (#7508)
cccc1e3 is described below
commit cccc1e3cd04286b99d2459f7541b159bc8d76bb7
Author: Rong Rong <wa...@gmail.com>
AuthorDate: Fri Oct 1 15:48:04 2021 -0700
fix volatile stopped flag (#7508)
---
.../org/apache/pinot/broker/broker/helix/ClusterChangeMediator.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/pinot-broker/src/main/java/org/apache/pinot/broker/broker/helix/ClusterChangeMediator.java b/pinot-broker/src/main/java/org/apache/pinot/broker/broker/helix/ClusterChangeMediator.java
index da4db31..5d442fa 100644
--- a/pinot-broker/src/main/java/org/apache/pinot/broker/broker/helix/ClusterChangeMediator.java
+++ b/pinot-broker/src/main/java/org/apache/pinot/broker/broker/helix/ClusterChangeMediator.java
@@ -63,7 +63,7 @@ public class ClusterChangeMediator
private final Thread _clusterChangeHandlingThread;
- private boolean _stopped = false;
+ private volatile boolean _stopped = false;
public ClusterChangeMediator(Map<ChangeType, List<ClusterChangeHandler>> changeHandlersMap,
BrokerMetrics brokerMetrics) {
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org