Repository: incubator-rya Updated Branches: refs/heads/master b42191bd8 -> fe7ca5d66
RYA-262 closes #147, Fixed a bug where AccumuloDocIdIndexer throws exceptions when the configured authorizations are either an empty string or not set. Project: http://git-wip-us.apache.org/repos/asf/incubator-rya/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-rya/commit/fe7ca5d6 Tree: http://git-wip-us.apache.org/repos/asf/incubator-rya/tree/fe7ca5d6 Diff: http://git-wip-us.apache.org/repos/asf/incubator-rya/diff/fe7ca5d6 Branch: refs/heads/master Commit: fe7ca5d66d6a1894c1f0678d8528be7e5961be4c Parents: b42191b Author: Kevin Chilton <[email protected]> Authored: Thu Mar 16 14:58:56 2017 -0400 Committer: pujav65 <[email protected]> Committed: Tue Apr 4 09:14:37 2017 -0400 ---------------------------------------------------------------------- .../indexing/accumulo/entity/AccumuloDocIdIndexer.java | 12 ++++++++++-- 1 file changed, 10 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/fe7ca5d6/extras/indexing/src/main/java/org/apache/rya/indexing/accumulo/entity/AccumuloDocIdIndexer.java ---------------------------------------------------------------------- diff --git a/extras/indexing/src/main/java/org/apache/rya/indexing/accumulo/entity/AccumuloDocIdIndexer.java b/extras/indexing/src/main/java/org/apache/rya/indexing/accumulo/entity/AccumuloDocIdIndexer.java index 39ca32d..a84670f 100644 --- a/extras/indexing/src/main/java/org/apache/rya/indexing/accumulo/entity/AccumuloDocIdIndexer.java +++ b/extras/indexing/src/main/java/org/apache/rya/indexing/accumulo/entity/AccumuloDocIdIndexer.java @@ -420,8 +420,16 @@ public class AccumuloDocIdIndexer implements DocIdIndexer { if (query.hasContext()) { DocumentIndexIntersectingIterator.setContext(is, query.getContextURI()); } - bs = accCon.createBatchScanner(EntityCentricIndex.getTableName(conf), - new Authorizations(conf.get(ConfigUtils.CLOUDBASE_AUTHS)), 15); + + final Authorizations auths; + final String authsStr = conf.get(ConfigUtils.CLOUDBASE_AUTHS); + if(authsStr == null || authsStr.isEmpty()) { + auths = new Authorizations(); + } else { + auths = new Authorizations(authsStr); + } + + bs = accCon.createBatchScanner(EntityCentricIndex.getTableName(conf), auths, 15); bs.addScanIterator(is); bs.setRanges(ranges);
