On 2016-09-26 13:42, [email protected] wrote:
On 2016-09-25 23:10, Chinmay Kolhatkar wrote:
Hi,
I can see RollingTopWordsDemo running fine in my local setup.
What variables did you set to configure your twitter credentials?
What xml file did you write them to?
Can you please share complete exception?
2nd attempt to answer this question because I think the first answered a
different one.
Hopefully this one is better.
Here's what I see in the dt.log file from one of the containers that is
killed:
2016-09-26 14:23:44,229 DEBUG twitter4j.TwitterStreamImpl: 404:The URI
requested is invalid or the resource requested, such as a user, does not
exist.
Unknown URL. See Twitter Streaming API documentation at
http://dev.twitter.com/pages/streaming_api
2016-09-26 14:23:44,230 ERROR
com.datatorrent.contrib.twitter.TwitterSampleInput: Sampling Error
404:The URI requested is invalid or the resource requested, such as a
user, does not exist.
Unknown URL. See Twitter Streaming API documentation at
http://dev.twitter.com/pages/streaming_api
Relevant discussions can be found on the Internet at:
http://www.google.co.jp/search?q=ec814753 or
http://www.google.co.jp/search?q=0a74cca1
TwitterException{exceptionCode=[ec814753-0a74cca1], statusCode=404,
retryAfter=-1, rateLimitStatus=null,
featureSpecificRateLimitStatus=null, version=2.2.6}
at
twitter4j.internal.http.HttpClientImpl.request(HttpClientImpl.java:185)
at
twitter4j.internal.http.HttpClientWrapper.request(HttpClientWrapper.java:65)
at
twitter4j.internal.http.HttpClientWrapper.get(HttpClientWrapper.java:93)
at
twitter4j.TwitterStreamImpl.getSampleStream(TwitterStreamImpl.java:160)
at twitter4j.TwitterStreamImpl$4.getStream(TwitterStreamImpl.java:149)
at twitter4j.TwitterStreamImpl$4.getStream(TwitterStreamImpl.java:147)
at
twitter4j.TwitterStreamImpl$TwitterStreamConsumer.run(TwitterStreamImpl.java:426)
2016-09-26 14:23:44,236 DEBUG
com.datatorrent.contrib.twitter.TwitterSampleInput: reconnect: false
2016-09-26 14:23:44,236 DEBUG twitter4j.TwitterStreamImpl: Twitter
Stream consumer-1[Disposing thread]
2016-09-26 14:23:44,237 ERROR
com.datatorrent.stram.engine.StreamingContainer: Operator set
[OperatorDeployInfo[id=1,name=TweetSampler,type=INPUT,checkpoint={57e9911c0000012b,
0,
0},inputs=[],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=text,streamId=TweetStream,bufferServer=<null>]]]]
stopped running due to an exception.
java.lang.RuntimeException: java.lang.InterruptedException: sleep
interrupted
at com.google.common.base.Throwables.propagate(Throwables.java:156)
at com.datatorrent.stram.engine.InputNode.run(InputNode.java:209)
at
com.datatorrent.stram.engine.StreamingContainer$2.run(StreamingContainer.java:1407)
Caused by: java.lang.InterruptedException: sleep interrupted
at java.lang.Thread.sleep(Native Method)
at com.datatorrent.stram.engine.InputNode.run(InputNode.java:101)
... 1 more
-Chinmay.
Thanks much,
-david
On Wed, Sep 21, 2016 at 1:06 AM, <[email protected]> wrote:
I'm trying to run the RollingTopWordsDemo option (#1) in the malhar
version 3.4 twitter demo,
and the TweetSampler operator gets the exception:
java.lang.RuntimeException: java.lang.InterruptedException: sleep
interrupted
at
com.google.common.base.Throwables.propagate(Throwables.java:156)
at
com.datatorrent.stram.engine.InputNode.run(InputNode.java:209)
at
com.datatorrent.stram.engine.StreamingContainer$2.run(StreamingContainer.java:1407)
Caused by: java.lang.InterruptedException: sleep interrupted
at java.lang.Thread.sleep(Native Method)
at
com.datatorrent.stram.engine.InputNode.run(InputNode.java:101)
... 1 more
I'm new to Apex, so I'm not sure how to debug this.
Any suggestions or ideas?
Thanks in advance,
-david
