:40 PM Casado Tejedor, Rubén <
>> ruben.casado.teje...@accenture.com> wrote:
>>
>>> Thanks Fabian. @Hequn Cheng Could you share the
>>> status? Thanks for your amazing work!
>>>
>>>
>>>
>>> *De: *Fabian Hueske
the
>> status? Thanks for your amazing work!
>>
>>
>>
>> *De: *Fabian Hueske
>> *Fecha: *viernes, 16 de agosto de 2019, 9:30
>> *Para: *"Casado Tejedor, Rubén"
>> *CC: *Maatary Okouya , miki haiat <
>> miko5...@gmail.com>, user
;
> chenghe...@gmail.com>
> *Asunto: *Re: [External] Re: From Kafka Stream to Flink
>
>
>
> Hi Ruben,
>
>
>
> Work on this feature has already started [1], but stalled a bit (probably
> due to the effort of merging the new Blink query processor).
>
> Hequn (
ternal] Re: From Kafka Stream to Flink
Hi Ruben,
Work on this feature has already started [1], but stalled a bit (probably due
to the effort of merging the new Blink query processor).
Hequn (in CC) is the guy working on upsert table ingestion, maybe he can share
what the status of this feature i
Hi Ruben,
Work on this feature has already started [1], but stalled a bit (probably
due to the effort of merging the new Blink query processor).
Hequn (in CC) is the guy working on upsert table ingestion, maybe he can
share what the status of this feature is.
Best, Fabian
[1] https://github.com/
Hi
Do you have an expected version of Flink to include the capability to ingest an
upsert stream as a dynamic table? We have such need in our current project.
What we have done is to emulate such behavior working at low level with states
(e.g. update existing value if key exists, create a new v
