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

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


The following commit(s) were added to refs/heads/2.1 by this push:
     new 04f5aaf7c2 Improves log message for missing iterator class (#4591)
04f5aaf7c2 is described below

commit 04f5aaf7c27695b6d4ac0383bf79ef74ed3e54a8
Author: Daniel Roberts <ddani...@gmail.com>
AuthorDate: Tue May 28 15:11:14 2024 -0400

    Improves log message for missing iterator class (#4591)
---
 .../accumulo/core/iteratorsImpl/IteratorConfigUtil.java     | 13 +++++++------
 1 file changed, 7 insertions(+), 6 deletions(-)

diff --git 
a/core/src/main/java/org/apache/accumulo/core/iteratorsImpl/IteratorConfigUtil.java
 
b/core/src/main/java/org/apache/accumulo/core/iteratorsImpl/IteratorConfigUtil.java
index 09c087a913..93c098d0ef 100644
--- 
a/core/src/main/java/org/apache/accumulo/core/iteratorsImpl/IteratorConfigUtil.java
+++ 
b/core/src/main/java/org/apache/accumulo/core/iteratorsImpl/IteratorConfigUtil.java
@@ -199,9 +199,8 @@ public class IteratorConfigUtil {
     final boolean useClassLoader = iteratorBuilder.useAccumuloClassLoader;
     Map<String,Class<SortedKeyValueIterator<Key,Value>>> classCache = new 
HashMap<>();
 
-    try {
-      for (IterInfo iterInfo : iteratorBuilder.iters) {
-
+    for (IterInfo iterInfo : iteratorBuilder.iters) {
+      try {
         Class<SortedKeyValueIterator<Key,Value>> clazz = null;
         log.trace("Attempting to load iterator class {}", iterInfo.className);
         if (iteratorBuilder.useClassCache) {
@@ -225,10 +224,12 @@ public class IteratorConfigUtil {
 
         skvi.init(prev, options, iteratorBuilder.iteratorEnvironment);
         prev = skvi;
+
+      } catch (ReflectiveOperationException e) {
+        log.error("Failed to load iterator {}, for table {}, from context {}", 
iterInfo.className,
+            iteratorBuilder.iteratorEnvironment.getTableId(), 
iteratorBuilder.context, e);
+        throw new RuntimeException(e);
       }
-    } catch (ReflectiveOperationException e) {
-      log.error(e.toString());
-      throw new RuntimeException(e);
     }
     return prev;
   }

Reply via email to