You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by kt...@apache.org on 2023/05/30 23:11:37 UTC

[accumulo] branch elasticity updated: avoids split inspection in manager if operation id is set

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 <kt...@apache.org>
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);