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

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


The following commit(s) were added to refs/heads/main by this push:
     new 39bcf83d32 fixes tests in ExternalCompaction2IT (#6273)
39bcf83d32 is described below

commit 39bcf83d328075b5814aa2bc72ce2dc4eeb4efc8
Author: Keith Turner <[email protected]>
AuthorDate: Mon Mar 30 11:52:39 2026 -0700

    fixes tests in ExternalCompaction2IT (#6273)
    
    Multiple tests in ExternalCompactoin2IT that were using the
    ExternalDoNothingCompactor were failing.  The reason was the
    ExternalDoNothingCompactor was not setting a status update like the
    normal Compactor code does. The test code were looking for these statup
    updates.
---
 .../apache/accumulo/test/compaction/ExternalDoNothingCompactor.java  | 5 +++++
 1 file changed, 5 insertions(+)

diff --git 
a/test/src/main/java/org/apache/accumulo/test/compaction/ExternalDoNothingCompactor.java
 
b/test/src/main/java/org/apache/accumulo/test/compaction/ExternalDoNothingCompactor.java
index afa424d5c3..2a66707fda 100644
--- 
a/test/src/main/java/org/apache/accumulo/test/compaction/ExternalDoNothingCompactor.java
+++ 
b/test/src/main/java/org/apache/accumulo/test/compaction/ExternalDoNothingCompactor.java
@@ -28,6 +28,8 @@ import java.util.concurrent.atomic.LongAdder;
 
 import org.apache.accumulo.compactor.Compactor;
 import org.apache.accumulo.core.cli.ServerOpts;
+import org.apache.accumulo.core.compaction.thrift.TCompactionState;
+import org.apache.accumulo.core.compaction.thrift.TCompactionStatusUpdate;
 import org.apache.accumulo.core.dataImpl.KeyExtent;
 import org.apache.accumulo.core.metadata.ReferencedTabletFile;
 import org.apache.accumulo.core.metadata.schema.ExternalCompactionId;
@@ -114,6 +116,9 @@ public class ExternalDoNothingCompactor extends Compactor {
 
       @Override
       public void initialize() throws RetriesExceededException {
+        TCompactionStatusUpdate update = new 
TCompactionStatusUpdate(TCompactionState.STARTED,
+            "Compaction started", -1, -1, -1, getCompactionAge().toNanos());
+        updateCompactionState(job, update);
         // This isn't used, just need to create and return something
         ref.set(new FileCompactor(getContext(), 
KeyExtent.fromThrift(job.getExtent()), null, null,
             false, null, null, null, null, null));

Reply via email to