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

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

commit 81a2581ead2323326d2c89472922ff078ec42382
Merge: 0f060b9cb0 d925db128b
Author: Keith Turner <ktur...@apache.org>
AuthorDate: Thu Mar 30 20:08:18 2023 -0400

    Merge remote-tracking branch 'upstream/1.10' into 2.1

 .../java/org/apache/accumulo/tserver/tablet/Tablet.java  | 16 ++++++++++------
 1 file changed, 10 insertions(+), 6 deletions(-)

diff --cc 
server/tserver/src/main/java/org/apache/accumulo/tserver/tablet/Tablet.java
index 5c4b7d40db,9cd5cbd968..fbdec25e97
--- 
a/server/tserver/src/main/java/org/apache/accumulo/tserver/tablet/Tablet.java
+++ 
b/server/tserver/src/main/java/org/apache/accumulo/tserver/tablet/Tablet.java
@@@ -43,11 -45,9 +44,10 @@@ import java.util.concurrent.ConcurrentS
  import java.util.concurrent.TimeUnit;
  import java.util.concurrent.atomic.AtomicBoolean;
  import java.util.concurrent.atomic.AtomicLong;
--import java.util.concurrent.atomic.AtomicReference;
  import java.util.concurrent.locks.Lock;
  import java.util.concurrent.locks.ReentrantLock;
 +import java.util.stream.Collectors;
 +import java.util.stream.Stream;
  
  import org.apache.accumulo.core.Constants;
  import org.apache.accumulo.core.client.Durability;
@@@ -1400,10 -1875,12 +1404,12 @@@ public class Tablet extends TabletBase 
          }
  
          newComputation = new SplitComputations(files, midpoint, lastRow);
+ 
+         lastSplitComputation = new SoftReference<>(newComputation);
        } catch (IOException e) {
-         lastSplitComputation.set(null);
+         lastSplitComputation.clear();
          log.error("Failed to compute split information from files " + 
e.getMessage());
 -        return Optional.absent();
 +        return Optional.empty();
        } finally {
          splitComputationLock.unlock();
        }

Reply via email to