You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rya.apache.org by pu...@apache.org on 2017/04/04 13:15:06 UTC
incubator-rya git commit: RYA-262 closes #147,
Fixed a bug where AccumuloDocIdIndexer throws exceptions when the
configured authorizations are either an empty string or not set.
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 <ke...@parsons.com>
Authored: Thu Mar 16 14:58:56 2017 -0400
Committer: pujav65 <pu...@gmail.com>
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);