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