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/02 18:13:55 UTC
[04/12] git commit: good catch Matt F.
good catch Matt F.
Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/2e829d8d
Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/2e829d8d
Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/2e829d8d
Branch: refs/heads/instagram
Commit: 2e829d8dcd3deb25ec463fe5f15bb7e8c7d32edf
Parents: e0e4ad4
Author: Matthew Hager <Ma...@gmail.com>
Authored: Fri Jun 27 11:17:24 2014 -0500
Committer: Matthew Hager <Ma...@gmail.com>
Committed: Fri Jun 27 11:17:24 2014 -0500
----------------------------------------------------------------------
.../apache/streams/elasticsearch/ElasticsearchPersistWriter.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/2e829d8d/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 c40cbfa..5956808 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
@@ -243,7 +243,7 @@ public class ElasticsearchPersistWriter implements StreamsPersistWriter, DatumSt
try {
Thread.yield();
Thread.sleep(1);
- timeOutThresholdInMS++;
+ counter++;
} catch(InterruptedException ie) {
// No Operation
}