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);