You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by kt...@apache.org on 2024/01/26 20:28:35 UTC

(accumulo) branch main updated (97f9cf80cb -> b85cafb61c)

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

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


    from 97f9cf80cb Merge remote-tracking branch 'upstream/2.1'
     add 5401dedda0 Fixes RowFilter bug with deep copy (#4197)
     new b85cafb61c Merge branch '2.1'

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.


Summary of changes:
 .../accumulo/core/iterators/user/RowFilter.java    |  7 +-
 .../core/iterators/user/RowFilterTest.java         | 89 ++++++++++++++++++++++
 2 files changed, 95 insertions(+), 1 deletion(-)


(accumulo) 01/01: Merge branch '2.1'

Posted by kt...@apache.org.
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

commit b85cafb61c5d3036a40a8e0c9ca9da3f02302d5d
Merge: 97f9cf80cb 5401dedda0
Author: Keith Turner <kt...@apache.org>
AuthorDate: Fri Jan 26 15:26:23 2024 -0500

    Merge branch '2.1'

 .../accumulo/core/iterators/user/RowFilter.java    |  7 +-
 .../core/iterators/user/RowFilterTest.java         | 89 ++++++++++++++++++++++
 2 files changed, 95 insertions(+), 1 deletion(-)

diff --cc core/src/main/java/org/apache/accumulo/core/iterators/user/RowFilter.java
index a6849e448b,54d8b0978d..ac93ab1455
--- a/core/src/main/java/org/apache/accumulo/core/iterators/user/RowFilter.java
+++ b/core/src/main/java/org/apache/accumulo/core/iterators/user/RowFilter.java
@@@ -19,6 -19,6 +19,7 @@@
  package org.apache.accumulo.core.iterators.user;
  
  import java.io.IOException;
++import java.io.UncheckedIOException;
  import java.util.Collection;
  import java.util.Map;
  
@@@ -155,10 -157,10 +158,12 @@@ public abstract class RowFilter extend
      RowFilter newInstance;
      try {
        newInstance = getClass().getDeclaredConstructor().newInstance();
+       newInstance.init(getSource().deepCopy(env), options, env);
 -    } catch (Exception e) {
 -      throw new RuntimeException(e);
 +    } catch (ReflectiveOperationException e) {
 +      throw new IllegalStateException(e);
++    } catch (IOException e) {
++      throw new UncheckedIOException(e);
      }
-     newInstance.setSource(getSource().deepCopy(env));
      newInstance.decisionIterator = new RowIterator(getSource().deepCopy(env));
      return newInstance;
    }