From 2d22d649c4a3bf79e367d25019f0a9826dc0780d Mon Sep 17 00:00:00 2001 From: Dave Marion Date: Fri, 20 Dec 2024 19:02:59 +0000 Subject: [PATCH] Forgot to add new Thrift API to Coordinator subclasses --- .../apache/accumulo/coordinator/CompactionCoordinatorTest.java | 3 ++- .../compaction/TestCompactionCoordinatorForOfflineTable.java | 3 ++- 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/server/compaction-coordinator/src/test/java/org/apache/accumulo/coordinator/CompactionCoordinatorTest.java b/server/compaction-coordinator/src/test/java/org/apache/accumulo/coordinator/CompactionCoordinatorTest.java index 5bef12df8f7..e48f8c0cec4 100644 --- a/server/compaction-coordinator/src/test/java/org/apache/accumulo/coordinator/CompactionCoordinatorTest.java +++ b/server/compaction-coordinator/src/test/java/org/apache/accumulo/coordinator/CompactionCoordinatorTest.java @@ -51,6 +51,7 @@ import org.apache.accumulo.core.metadata.TServerInstance; import org.apache.accumulo.core.metadata.schema.ExternalCompactionId; import org.apache.accumulo.core.metrics.MetricsInfo; +import org.apache.accumulo.core.process.thrift.ServerProcessService; import org.apache.accumulo.core.rpc.ThriftUtil; import org.apache.accumulo.core.securityImpl.thrift.TCredentials; import org.apache.accumulo.core.tabletserver.thrift.TCompactionQueueSummary; @@ -92,7 +93,7 @@ "com.sun.org.apache.xerces.*"}) public class CompactionCoordinatorTest { - public class TestCoordinator extends CompactionCoordinator { + public class TestCoordinator extends CompactionCoordinator implements ServerProcessService.Iface { private final ServerContext context; private final ServerAddress client; diff --git a/test/src/main/java/org/apache/accumulo/test/compaction/TestCompactionCoordinatorForOfflineTable.java b/test/src/main/java/org/apache/accumulo/test/compaction/TestCompactionCoordinatorForOfflineTable.java index 7e5242b6fa1..87ede2e97ed 100644 --- a/test/src/main/java/org/apache/accumulo/test/compaction/TestCompactionCoordinatorForOfflineTable.java +++ b/test/src/main/java/org/apache/accumulo/test/compaction/TestCompactionCoordinatorForOfflineTable.java @@ -27,6 +27,7 @@ import org.apache.accumulo.core.dataImpl.KeyExtent; import org.apache.accumulo.core.metadata.schema.ExternalCompactionFinalState; import org.apache.accumulo.core.metadata.schema.ExternalCompactionFinalState.FinalState; +import org.apache.accumulo.core.process.thrift.ServerProcessService; import org.apache.accumulo.core.metadata.schema.ExternalCompactionId; import org.apache.accumulo.server.ServerContext; import org.apache.accumulo.server.ServerOpts; @@ -34,7 +35,7 @@ import org.slf4j.LoggerFactory; public class TestCompactionCoordinatorForOfflineTable extends CompactionCoordinator - implements CompactionCoordinatorService.Iface { + implements CompactionCoordinatorService.Iface, ServerProcessService.Iface { public static class NonNotifyingCompactionFinalizer extends CompactionFinalizer {