You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by mm...@apache.org on 2021/10/13 17:46:00 UTC

[accumulo] branch main updated: Improve error message in CompactionService. Closes #2311 (#2315)

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

mmiller 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 eaa8268  Improve error message in CompactionService. Closes #2311 (#2315)
eaa8268 is described below

commit eaa8268f3835733283f8a1ffcabdf5101135a4f3
Author: Mike Miller <mm...@apache.org>
AuthorDate: Wed Oct 13 13:45:52 2021 -0400

    Improve error message in CompactionService. Closes #2311 (#2315)
---
 .../org/apache/accumulo/tserver/compactions/CompactionService.java     | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/server/tserver/src/main/java/org/apache/accumulo/tserver/compactions/CompactionService.java b/server/tserver/src/main/java/org/apache/accumulo/tserver/compactions/CompactionService.java
index 43f1363..c5ea507 100644
--- a/server/tserver/src/main/java/org/apache/accumulo/tserver/compactions/CompactionService.java
+++ b/server/tserver/src/main/java/org/apache/accumulo/tserver/compactions/CompactionService.java
@@ -132,7 +132,8 @@ public class CompactionService {
         @Override
         public CompactionExecutorId getExternalExecutor(String name) {
           var ceid = CompactionExecutorIdImpl.externalId(name);
-          Preconditions.checkArgument(!requestedExternalExecutors.contains(ceid));
+          Preconditions.checkArgument(!requestedExternalExecutors.contains(ceid),
+              "Duplicate external executor for queue " + name);
           requestedExternalExecutors.add(ceid);
           return ceid;
         }