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*
