Apache
/
lucene
mirror of https://github.com/apache/lucene.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

SOLR-8655: DaemonStream should 'put' EOF Tuple on the blocking queue

This commit is contained in:
jbernste 2016-02-07 20:41:02 -05:00
parent 7053a99f49
commit 23fe5f2dc5
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/DaemonStream.java
View File

@ -282,7 +282,11 @@ public class DaemonStream extends TupleStream implements Expressible {
Map m = new HashMap();
m.put("EOF", true);
Tuple tuple = new Tuple(m);
queue.offer(tuple);
try {
queue.put(tuple);
} catch (InterruptedException e) {
logger.error("Error in DaemonStream", e);
}
}
setStopTime(new Date().getTime());
}