I am wondering if the Kafka connectors leverage Kafka message keys at all?
Looking through the docs my impression is that it does not. E.g. if I use
the connector to consume from a partitioned Kafka topic, what I will get
back is a DataStream, rather than a KeyedStream. And if I want access to a
Hi Riccardo,
I don't think you can use delta iterations when your solution set changes
over time.
For those cases, I would use the bulk iterations in Flink.
On Mon, Mar 21, 2016 at 12:26 PM, Riccardo Diomedi <
riccardo.diomed...@gmail.com> wrote:
> I try to explain my situation
>
> I’m doing a d
Hi Simone,
do you have a stack trace for the error?
Usually the user code serialization is the same locally and on a cluster.
On Tue, Apr 5, 2016 at 12:02 PM, Simone Robutti <
simone.robu...@radicalbit.io> wrote:
> Hello,
>
> last week I got a problem where my job worked in local mode but could
