Weird Kryo exception (Unable to find class: java.ttil.HashSet)

2016-05-15 Thread Flavio Pompermaier
Hi to all, in my last run of a job I received this weird Kryo Exception in one of the TaskManager...obviously this class in not mentioned anywhere, neither in my project nor in flink... Any help is appreciated! Best, Flavio INFO org.apache.flink.runtime.taskmanager.Task - CHAIN GroupReduce (Grou

Re: Regarding Broadcast of datasets in streaming context

2016-05-15 Thread Biplob Biswas
Hi Gyula, even after trying different things, I can't seem to get the hold of things. Also, i asked another question on the working of iteration and streaming here Be

Re: Regarding Broadcast of datasets in streaming context

2016-05-15 Thread Gyula Fóra
Hi, If you haven't done so far please read the respective part of the the streaming docs: https://ci.apache.org/projects/flink/flink-docs-master/apis/streaming/index.html#iterations Iterations just allow you to define cyclic flows, there is nothing magic about it. If your original input stream is

Re: Custom Source Function for reading JSON?

2016-05-15 Thread Gábor Horváth
Hi! On 14 May 2016 at 23:47, iñaki williams wrote: > Hi Flink Community! > > I am new using Apache Flink and I have a problem reading a JSON. > > I am using a JSON from a webpage, this JSON is changing continuosly so I > decided to use my own Source Function in order to grab the JSON using a URL

Re: Custom Source Function for reading JSON?

2016-05-15 Thread iñaki williams
Hi! I have the class, I want to create objects using the values extraced from the JSON text, my fault haha. Sorry for that 2016-05-15 19:10 GMT+02:00 Gábor Horváth : > Hi! > > On 14 May 2016 at 23:47, iñaki williams wrote: > >> Hi Flink Community! >> >> I am new using Apache Flink and I have a

Re: Regarding Broadcast of datasets in streaming context

2016-05-15 Thread Biplob Biswas
Hi, i read that article already but it is very simplistic and thus based on that article and other examples, i was trying to understand how my centroids can be sent to all the partitions and update accordingly. I also understood that the order of the input and the feedback stream cant be determin