Question about StreamRecord.uid in flink-streaming

classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|

Question about StreamRecord.uid in flink-streaming

Aljoscha Krettek-2
Hi,
why do we have that field? It seems it is not used anywhere. And then,
as a follow up: why do we have the StreamRecord and
StreamRecordSerializer at all?

Sorry if this is a stupid question, just getting into flink-streaming here... :D

Cheers,
Aljoscha
Reply | Threaded
Open this post in threaded view
|

Re: Question about StreamRecord.uid in flink-streaming

Márton Balassi
Hi,

It is for the soon to come streaming fault tolerance purposes - tracking
the records by the unique ID. Currently it is unused.

Best,

Marton

On Thu, Feb 5, 2015 at 4:20 PM, Aljoscha Krettek <[hidden email]>
wrote:

> Hi,
> why do we have that field? It seems it is not used anywhere. And then,
> as a follow up: why do we have the StreamRecord and
> StreamRecordSerializer at all?
>
> Sorry if this is a stupid question, just getting into flink-streaming
> here... :D
>
> Cheers,
> Aljoscha
>