Trying to write a Twitter exampe on the Flink streamer-
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
Thanks, I plan on adding the example back in once it is done (still have to
parse the tweets).
*"Fortunate is he, who is able to know the causes of things." -Virgil*