Revision 52478
Added by Alessia Bardi almost 6 years ago
| VirtuosoParthenosIterator.java | ||
|---|---|---|
| 186 | 186 |
try {
|
| 187 | 187 |
verifyStarted(); |
| 188 | 188 |
} catch (Exception e) {
|
| 189 |
executor.shutdownNow();
|
|
| 189 |
getExecutor().shutdownNow();
|
|
| 190 | 190 |
throw new CollectorServiceRuntimeException(e); |
| 191 | 191 |
} |
| 192 | 192 |
switch(currentElement){
|
| ... | ... | |
| 203 | 203 |
|
| 204 | 204 |
@Override |
| 205 | 205 |
public String doNext() {
|
| 206 |
try {
|
|
| 207 |
verifyStarted(); |
|
| 208 |
} catch (Exception e) {
|
|
| 209 |
executor.shutdownNow(); |
|
| 210 |
throw new CollectorServiceRuntimeException(e); |
|
| 206 |
if(!hasNext()) {
|
|
| 207 |
log.error("Next called but hasNext is false", new NoSuchElementException());
|
|
| 208 |
throw new NoSuchElementException(); |
|
| 211 | 209 |
} |
| 212 | 210 |
switch(currentElement){
|
| 213 | 211 |
case TERMINATOR: |
Also available in: Unified diff
Revised publishign workflows for the index, as it seems we are having troubles when the resultset is created from Iterables.concat