Re: Early firing window implementation issue

Hi all Any recommendation about the issue? Regards 25 Tem 2019 Per 22:37 tarihinde Ceyhan Kasap şunu yazdı: > Hi, > > I am having quite hard time to understand flink windowing principals and > would be very pleased if you could point me in the right direction. > > My purpose is to count the nu

Re: How to access state from another map functions

Hi Biao Thank you for your reply. I will consulting in-memory DB. On 2019/07/29 14:52, Biao Liu wrote: Hi Yuta, No, you can't get the same state from different functions. That's not the semantics of state. And these two functions might run in different threads/processes even on different ma

Re: How to access state from another map functions

Hi Yuta, No, you can't get the same state from different functions. That's not the semantics of state. And these two functions might run in different threads/processes even on different machines. On Mon, Jul 29, 2019 at 11:12 AM Yuta Morisawa wrote: > Hi all > > I want to use the same state for

Re: Is it possible to decide the order of where conditions in Flink SQL

Hi Hequn, Thank you very much. It's helpful to me. For clarification, I think the code should look like the following snippet, since original query was an `AND` operator. Am I right? > CASE > WHEN user_robot THEN false > WHEN !UDF_NEED_TO_QUERY_DB(user) THEN false > ELSE true > END Best regard

How to access state from another map functions

Hi all I want to use the same state for multiple times. stream .keyBy(0) .map(new MyRichMapfunction) ... .keyBy(0) .map(new MyRichMapfunction2) In this snippet, I want access the same state in MyRichMapfunction and MyRichMapfunction2, but I failed in spite of keying the same key. Is there any

[ANNOUNCE] Weekly Community Update 2019/30

Dear community, happy to share this week's community update with news about a Flink on PyPi, two proposal on the Table API/SQL and a bit more. As always, please feel free to add additional updates and news to this thread! Flink Development === [sql] *Temporary tables* are always reg

Re: Is it possible to decide the order of where conditions in Flink SQL

Hi Tony, There is no order guarantee for filter conditions. The conditions would be pushed down or merged during query optimization. However, you can use the case when[1] to achieve what you want. The code looks like: CASE WHEN !user.is_robot THEN true WHEN UDF_NEED_TO_QUERY_DB(user) THEN true EL