(accumulo) branch 2.1 updated: Remove inaccurate @NotThreadSafe from InMemoryMap.MemoryDataSource (#6522)

[domgarguilo]

This is an automated email from the ASF dual-hosted git repository.

DomGarguilo pushed a commit to branch 2.1
in repository https://gitbox.apache.org/repos/asf/accumulo.git


The following commit(s) were added to refs/heads/2.1 by this push:
     new c186563b64 Remove inaccurate @NotThreadSafe from 
InMemoryMap.MemoryDataSource (#6522)
c186563b64 is described below

commit c186563b64e388582e05b8536af705e855d04bb2
Author: Dom G. <domgargu...@apache.org>
AuthorDate: Mon Aug 31 17:29:53 2026 -0400

    Remove inaccurate @NotThreadSafe from InMemoryMap.MemoryDataSource (#6522)
---
 .../src/main/java/org/apache/accumulo/tserver/InMemoryMap.java       | 5 +----
 1 file changed, 1 insertion(+), 4 deletions(-)

diff --git 
a/server/tserver/src/main/java/org/apache/accumulo/tserver/InMemoryMap.java 
b/server/tserver/src/main/java/org/apache/accumulo/tserver/InMemoryMap.java
index c8182e6e1f..9c80197a13 100644
--- a/server/tserver/src/main/java/org/apache/accumulo/tserver/InMemoryMap.java
+++ b/server/tserver/src/main/java/org/apache/accumulo/tserver/InMemoryMap.java
@@ -37,8 +37,6 @@ import java.util.concurrent.atomic.AtomicInteger;
 import java.util.concurrent.atomic.AtomicLong;
 import java.util.concurrent.atomic.AtomicReference;
 
-import javax.annotation.concurrent.NotThreadSafe;
-
 import org.apache.accumulo.core.client.SampleNotPresentException;
 import org.apache.accumulo.core.client.sample.Sampler;
 import org.apache.accumulo.core.conf.AccumuloConfiguration;
@@ -533,10 +531,9 @@ public class InMemoryMap {
 
   private final Set<MemoryIterator> activeIters = 
Collections.synchronizedSet(new HashSet<>());
 
-  @NotThreadSafe
   class MemoryDataSource implements DataSource {
 
-    private boolean switched = false;
+    private volatile boolean switched = false;
     private InterruptibleIterator iter;
     private FileSKVIterator reader;
     private final MemoryDataSource parent;