Hi,

Trying to write a Twitter exampe on the Flink streamer-

https://github.com/rawkintrevo/incubator-beam/blob/flink-twitter-example/runners/flink/examples/src/main/java/org/apache/beam/runners/flink/examples/streaming/TwitterWindowedWordCountExamples.java

I'm getting an error
Caused by: java.lang.IllegalArgumentException: Write can only be applied to
a Bounded PCollection

I was nearly copy and pasting from the other word count example, every
thing looks good in intellij. Can't figure out for the life of me what I'm
doing wrong here.

I am running the job against a flink cluster (uploaded via web-UI) if that
is informative...

Thanks, I plan on adding the example back in once it is done (still have to
parse the tweets).

tg


Trevor Grant
Data Scientist
https://github.com/rawkintrevo
http://stackexchange.com/users/3002022/rawkintrevo
http://trevorgrant.org

*"Fortunate is he, who is able to know the causes of things."  -Virgil*

Reply via email to