Re: Broadcasting control messages to a sink

2020-10-17 Thread Piotr Nowojski
Hi Julian, Glad to hear it worked! And thanks for coming back to us :) Best, Piotrek sob., 17 paź 2020 o 04:22 Jaffe, Julian napisał(a): > Hey Piotr, > > > > Thanks for your help! The main thing I was missing was the .broadcast > partition operation on a stream (searching for “broadcasting” ob

Remote Stateful Function Scalability

2020-10-17 Thread Elias Levy
After reading the Stateful Functions documentation, I am left wondering how remote stateful functions scale. The documentation mentions that the use of remote functions allows the state and compute tiers to scale independently. But the documentation seems to imply that only a single instance of a

Re: PyFlink:

2020-10-17 Thread Dian Fu
Hi Thilo, You need also add the transitive dependencies of Avro, e.g. jackson-core-asl, jackson-mapper-asl, etc. It will provided a uber jar since 1.12, you could refer https://issues.apache.org/jira/browse/FLINK-18802 for more details. Regar

Re: Remote Stateful Function Scalability

2020-10-17 Thread Tzu-Li (Gordon) Tai
Hi Elias, On Sun, Oct 18, 2020 at 6:16 AM Elias Levy wrote: > After reading the Stateful Functions documentation, I am left wondering > how remote stateful functions scale. > > The documentation mentions that the use of remote functions allows the > state and compute tiers to scale independently

how to print for result1 in this code

2020-10-17 Thread ??????
I'm learning official document But the example is not complete. The code is: https://paste.ubuntu.com/p/Mx96MWjQ83/ Could you tell me how to print result1 in above code? (The above code is wrong) Thanks for your help.