Hi,

I can see RollingTopWordsDemo running fine in my local setup.
Can you please share complete exception?

Also, Do you see TwitterSampleInput class mentioned in exception anywhere?

-Chinmay.


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(Stream
> ingContainer.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
>
>

Reply via email to