Repository: incubator-streams-examples Updated Branches: refs/heads/master 6fa84b721 -> 2d443be05
this test needs a timeout on the stream or itâll 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 <[email protected]> Authored: Thu Oct 20 13:27:47 2016 -0500 Committer: Steve Blackmon @steveblackmon <[email protected]> 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
