diff --git a/engine/src/main/java/org/archive/crawler/frontier/URIAuthorityBasedQueueAssignmentPolicy.java b/engine/src/main/java/org/archive/crawler/frontier/URIAuthorityBasedQueueAssignmentPolicy.java index c2c0d351..875f8d16 100644 --- a/engine/src/main/java/org/archive/crawler/frontier/URIAuthorityBasedQueueAssignmentPolicy.java +++ b/engine/src/main/java/org/archive/crawler/frontier/URIAuthorityBasedQueueAssignmentPolicy.java @@ -100,6 +100,9 @@ implements } protected int getSubqueue(UURI basis, int parallelQueues) { + if(null==basis.getRawPathQuery()) { + return 0; + } return conhash.bucketFor(basis.getRawPathQuery(), parallelQueues); }