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

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


The following commit(s) were added to refs/heads/elasticity by this push:
     new c8d39de73d avoids split inspection in manager if operation id is set
c8d39de73d is described below

commit c8d39de73d7984a490c3693aa9760c96546b1bb2
Author: Keith Turner <[email protected]>
AuthorDate: Tue May 30 19:11:23 2023 -0400

    avoids split inspection in manager if operation id is set
---
 .../main/java/org/apache/accumulo/manager/split/SplitTask.java   | 9 +++++++++
 1 file changed, 9 insertions(+)

diff --git 
a/server/manager/src/main/java/org/apache/accumulo/manager/split/SplitTask.java 
b/server/manager/src/main/java/org/apache/accumulo/manager/split/SplitTask.java
index 19ab1232ec..16f2682f98 100644
--- 
a/server/manager/src/main/java/org/apache/accumulo/manager/split/SplitTask.java
+++ 
b/server/manager/src/main/java/org/apache/accumulo/manager/split/SplitTask.java
@@ -57,6 +57,15 @@ public class SplitTask implements Runnable {
         }
       }
 
+      if (tablet.getOperationId() != null) {
+        // This will be checked in the FATE op, but no need to inspect files 
and start a FATE op if
+        // it currently has an operation running against it.
+        log.debug("Not splitting {} because it has operation id {}", 
tablet.getExtent(),
+            tablet.getOperationId());
+        manager.getSplitter().removeSplitStarting(tablet.getExtent());
+        return;
+      }
+
       var extent = tablet.getExtent();
 
       SortedSet<Text> splits = SplitUtils.findSplits(context, tablet);

Reply via email to