You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@lucene.apache.org by jb...@apache.org on 2016/02/08 02:37:26 UTC
lucene-solr git commit: SOLR-8655: DaemonStream should 'put' EOF
Tuple on the blocking queue
Repository: lucene-solr
Updated Branches:
refs/heads/master 7053a99f4 -> 23fe5f2dc
SOLR-8655: DaemonStream should 'put' EOF Tuple on the blocking queue
Project: http://git-wip-us.apache.org/repos/asf/lucene-solr/repo
Commit: http://git-wip-us.apache.org/repos/asf/lucene-solr/commit/23fe5f2d
Tree: http://git-wip-us.apache.org/repos/asf/lucene-solr/tree/23fe5f2d
Diff: http://git-wip-us.apache.org/repos/asf/lucene-solr/diff/23fe5f2d
Branch: refs/heads/master
Commit: 23fe5f2dc574f36c17a6308da92858bc0420c1b8
Parents: 7053a99
Author: jbernste <jb...@apache.org>
Authored: Sun Feb 7 20:41:02 2016 -0500
Committer: jbernste <jb...@apache.org>
Committed: Sun Feb 7 20:42:12 2016 -0500
----------------------------------------------------------------------
.../org/apache/solr/client/solrj/io/stream/DaemonStream.java | 6 +++++-
1 file changed, 5 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/lucene-solr/blob/23fe5f2d/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/DaemonStream.java
----------------------------------------------------------------------
diff --git a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/DaemonStream.java b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/DaemonStream.java
index 2d96c09..358eea4 100644
--- a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/DaemonStream.java
+++ b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/DaemonStream.java
@@ -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());
}