You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streams.apache.org by sb...@apache.org on 2016/10/20 18:28:05 UTC
incubator-streams-examples git commit: this test needs a timeout on the stream or it’ll run indefinitely.
Repository: incubator-streams-examples
Updated Branches:
refs/heads/master 6fa84b721 -> 2d443be05
this test needs a timeout on the stream or it\u2019ll run indefinitely.
Project: http://git-wip-us.apache.org/repos/asf/incubator-streams-examples/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams-examples/commit/2d443be0
Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams-examples/tree/2d443be0
Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams-examples/diff/2d443be0
Branch: refs/heads/master
Commit: 2d443be055556ebf997c9bd6b5c2dad4799296d8
Parents: 6fa84b7
Author: Steve Blackmon @steveblackmon <sb...@apache.org>
Authored: Thu Oct 20 13:27:47 2016 -0500
Committer: Steve Blackmon @steveblackmon <sb...@apache.org>
Committed: Thu Oct 20 13:27:47 2016 -0500
----------------------------------------------------------------------
.../streams/example/test/TwitterUserstreamElasticsearchIT.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-streams-examples/blob/2d443be0/local/twitter-userstream-elasticsearch/src/test/java/org/apache/streams/example/test/TwitterUserstreamElasticsearchIT.java
----------------------------------------------------------------------
diff --git a/local/twitter-userstream-elasticsearch/src/test/java/org/apache/streams/example/test/TwitterUserstreamElasticsearchIT.java b/local/twitter-userstream-elasticsearch/src/test/java/org/apache/streams/example/test/TwitterUserstreamElasticsearchIT.java
index e4103e4..f2dc6a8 100644
--- a/local/twitter-userstream-elasticsearch/src/test/java/org/apache/streams/example/test/TwitterUserstreamElasticsearchIT.java
+++ b/local/twitter-userstream-elasticsearch/src/test/java/org/apache/streams/example/test/TwitterUserstreamElasticsearchIT.java
@@ -82,7 +82,9 @@ public class TwitterUserstreamElasticsearchIT {
TwitterUserstreamElasticsearch stream = new TwitterUserstreamElasticsearch(testConfiguration);
- stream.run();
+ Thread thread = new Thread(stream);
+ thread.start();
+ thread.join(30000);
// assert lines in file
SearchRequestBuilder countRequest = testClient