Skip to content

Commit 5847052

Browse files
authored
Makes CompactionExecutorsMetrics.registry volatile (#5379)
This variable is accessed by multiple thread outside of sync block and is not final, so made if volatile to ensure changes are seen.
1 parent f297977 commit 5847052

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

server/tserver/src/main/java/org/apache/accumulo/tserver/metrics/CompactionExecutorsMetrics.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -47,7 +47,7 @@ public class CompactionExecutorsMetrics implements MetricsProducer {
4747
private volatile List<CeMetrics> ceMetricsList = List.of();
4848
private final Map<CompactionExecutorId,CeMetrics> ceMetricsMap = new HashMap<>();
4949
private final Map<CompactionExecutorId,ExMetrics> exCeMetricsMap = new HashMap<>();
50-
private MeterRegistry registry = null;
50+
private volatile MeterRegistry registry = null;
5151

5252
// public so it can be closed by outside callers
5353
public class CeMetrics implements AutoCloseable {

0 commit comments

Comments
 (0)