Hi!
I am new to Apache Flink and I would like to ask what is the best way to
query a relational DB inside a map function, in order to enrich the
streaming data. Consider, for example, that I have a KeyedStream[Int,
String] and I would like to query the database based on the Int value
inside a map
Hi Maciek,
Thanks for bringing this up again and sorry for not opening the discussion yet.
I will check it out and get back to you during week.
Kostas
> On Nov 26, 2016, at 9:40 PM, Maciek Próchniak wrote:
>
> Hi Kostas,
>
> I didn't see any discussion on dev mailing list, so I'd like to sha
Hi,
I want to run k-means with different k in parallel.
So each worker should calculate its own k-means. Is that possible?
If I do a map on a list of integers to then apply k-means I get the following
error:
Task not serializable
I am looking forward to your answers!
Lydia
