You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streams.apache.org by mf...@apache.org on 2014/07/14 14:23:13 UTC
git commit: STREAMS-131 | Because the elastic search components use
the same static client, closing the reader can close the writer
Repository: incubator-streams
Updated Branches:
refs/heads/STREAMS-131 d7c073c58 -> d41890d9a
STREAMS-131 | Because the elastic search components use the same static client, closing the reader can close the writer
Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/d41890d9
Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/d41890d9
Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/d41890d9
Branch: refs/heads/STREAMS-131
Commit: d41890d9adafc94a7d09227e57d0b811f293dbb9
Parents: d7c073c
Author: mfranklin <mf...@apache.org>
Authored: Mon Jul 14 08:23:01 2014 -0400
Committer: mfranklin <mf...@apache.org>
Committed: Mon Jul 14 08:23:01 2014 -0400
----------------------------------------------------------------------
.../apache/streams/elasticsearch/ElasticsearchPersistWriter.java | 1 -
.../java/org/apache/streams/elasticsearch/ElasticsearchQuery.java | 1 -
2 files changed, 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/d41890d9/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ElasticsearchPersistWriter.java
----------------------------------------------------------------------
diff --git a/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ElasticsearchPersistWriter.java b/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ElasticsearchPersistWriter.java
index 5b90e8b..05b0ef2 100644
--- a/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ElasticsearchPersistWriter.java
+++ b/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ElasticsearchPersistWriter.java
@@ -175,7 +175,6 @@ public class ElasticsearchPersistWriter implements StreamsPersistWriter, DatumSt
refreshIndexes();
LOGGER.debug("Closed ElasticSearch Writer: Ok[{}] Failed[{}] Orphaned[{}]", this.totalOk.get(), this.totalFailed.get(), this.getTotalOutstanding());
- manager.stop();
timer.cancel();
} catch (Throwable e) {
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/d41890d9/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ElasticsearchQuery.java
----------------------------------------------------------------------
diff --git a/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ElasticsearchQuery.java b/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ElasticsearchQuery.java
index 4dd3d28..defd9dc 100644
--- a/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ElasticsearchQuery.java
+++ b/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ElasticsearchQuery.java
@@ -248,7 +248,6 @@ public class ElasticsearchQuery implements Iterable<SearchHit>, Iterator<SearchH
}
public void cleanUp() {
- this.elasticsearchClientManager.stop();
}
protected boolean isCompleted() {