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,

Reply via email to