Hey Attila, Thanks for trying out streaming!
As for your issues: * Your simple topology: make sure that your user defined functions (e.g. ItemsKafkaSource) and the classes containing them are serializable, so that they can be shipped. For anything more specific if you can give send over your code to me I am more than happy to have a look at it. * Streaming wordcount not working without provided dataset: Yes, thanks for reporting it is my fault - which was known, but now I also have a JIRA [1] for it. :) However if you give it some input it should work. * Can you run the Twitter example locally by the way? [1] https://issues.apache.org/jira/browse/FLINK-1204 Cheers, Marton On Mon, Nov 3, 2014 at 2:53 PM, axt <[email protected]> wrote: > ClassNotFoundException: > com.gravityrd.flink.ItemsKafkaSource >
