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
