You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@flink.apache.org by Jaswin Shah <ja...@outlook.com> on 2020/08/14 09:39:21 UTC
Flink issue in emitting data to same sideoutput from onTimer and
processElement
Hi,
I have a coProcessFunction which emits data to same side output from processElement1 method and on timer method.But, data is not getting emitted to sideoutput from onTimer. Is it like to the same sideoutput, we can not emit data from onTimer and processElement methods?
Get Outlook for Android<https://aka.ms/ghei36>
Re: Flink issue in emitting data to same sideoutput from onTimer and
processElement
Posted by Dawid Wysakowicz <dw...@apache.org>.
It should work just fine. Can you share a minimal reproducible example
we can debug if the problem still remains?
Best,
Dawid
On 14/08/2020 11:39, Jaswin Shah wrote:
> I am using KeyedCoProcessFunction
>
> Get Outlook for Android <https://aka.ms/ghei36>
>
> ------------------------------------------------------------------------
> *From:* Jaswin Shah
> *Sent:* Friday, August 14, 2020 3:09:21 PM
> *To:* user@flink.apache.org <us...@flink.apache.org>; Dawid Wysakowicz
> <dw...@apache.org>; Yun Tang <my...@live.com>
> *Subject:* Flink issue in emitting data to same sideoutput from
> onTimer and processElement
>
> Hi,
>
> I have a coProcessFunction which emits data to same side output from
> processElement1 method and on timer method.But, data is not getting
> emitted to sideoutput from onTimer. Is it like to the same sideoutput,
> we can not emit data from onTimer and processElement methods?
>
>
> Get Outlook for Android <https://aka.ms/ghei36>
Re: Flink issue in emitting data to same sideoutput from onTimer and
processElement
Posted by Jaswin Shah <ja...@outlook.com>.
I am using KeyedCoProcessFunction
Get Outlook for Android<https://aka.ms/ghei36>
________________________________
From: Jaswin Shah
Sent: Friday, August 14, 2020 3:09:21 PM
To: user@flink.apache.org <us...@flink.apache.org>; Dawid Wysakowicz <dw...@apache.org>; Yun Tang <my...@live.com>
Subject: Flink issue in emitting data to same sideoutput from onTimer and processElement
Hi,
I have a coProcessFunction which emits data to same side output from processElement1 method and on timer method.But, data is not getting emitted to sideoutput from onTimer. Is it like to the same sideoutput, we can not emit data from onTimer and processElement methods?
Get Outlook for Android<https://aka.ms/ghei36>