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 2020/08/13 12:25:57 UTC

[accumulo] branch main updated (5815bf6 -> a165264)

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

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


    from 5815bf6  Make CI build on more branches (#1671)
     add e3a14cd  Modify Combiner init method to honor all options. Fixes #1678 (#1680)
     new a165264  Merge branch '1.9' into main

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:
 .../org/apache/accumulo/core/iterators/Combiner.java     | 16 ++++++++--------
 1 file changed, 8 insertions(+), 8 deletions(-)


[accumulo] 01/01: Merge branch '1.9' into main

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

commit a165264e714e01329af41954b00d0217e982dfce
Merge: 5815bf6 e3a14cd
Author: Mike Miller <mm...@apache.org>
AuthorDate: Thu Aug 13 08:12:31 2020 -0400

    Merge branch '1.9' into main

 .../org/apache/accumulo/core/iterators/Combiner.java     | 16 ++++++++--------
 1 file changed, 8 insertions(+), 8 deletions(-)

diff --cc core/src/main/java/org/apache/accumulo/core/iterators/Combiner.java
index 6581195,7e24f88..c943a8e
--- a/core/src/main/java/org/apache/accumulo/core/iterators/Combiner.java
+++ b/core/src/main/java/org/apache/accumulo/core/iterators/Combiner.java
@@@ -277,18 -278,18 +277,18 @@@ public abstract class Combiner extends 
      combineAllColumns = false;
      if (options.containsKey(ALL_OPTION)) {
        combineAllColumns = Boolean.parseBoolean(options.get(ALL_OPTION));
-       if (combineAllColumns)
-         return;
      }
  
-     if (!options.containsKey(COLUMNS_OPTION))
-       throw new IllegalArgumentException("Must specify " + COLUMNS_OPTION + " option");
+     if (!combineAllColumns) {
+       if (!options.containsKey(COLUMNS_OPTION))
+         throw new IllegalArgumentException("Must specify " + COLUMNS_OPTION + " option");
  
-     String encodedColumns = options.get(COLUMNS_OPTION);
-     if (encodedColumns.isEmpty())
-       throw new IllegalArgumentException("The " + COLUMNS_OPTION + " must not be empty");
+       String encodedColumns = options.get(COLUMNS_OPTION);
 -      if (encodedColumns.length() == 0)
++      if (encodedColumns.isEmpty())
+         throw new IllegalArgumentException("The " + COLUMNS_OPTION + " must not be empty");
  
-     combiners = new ColumnSet(Lists.newArrayList(Splitter.on(",").split(encodedColumns)));
+       combiners = new ColumnSet(Lists.newArrayList(Splitter.on(",").split(encodedColumns)));
+     }
  
      isMajorCompaction = env.getIteratorScope() == IteratorScope.majc;