Re: [DISCUSS] Contribution of Multi Cluster Kafka Source

Hi all, Thanks for the feedback! I'm adding the users, who responded in the user mailing list, to this thread. @Qingsheng - Yes, I would prefer to reuse the existing Kafka connector module. It makes a lot of sense since the dependencies are the same and the implementation can also extend and impr

Re: [ANNOUNCE] Apache Flink Kubernetes Operator 1.0.1 released

Thanks Gyula for working on the first patch release for the Flink Kubernetes Operator project. Best, Yang Gyula Fóra 于2022年6月28日周二 00:22写道： > The Apache Flink community is very happy to announce the release of Apache > Flink Kubernetes Operator 1.0.1. > > The Flink Kubernetes Operator allows

Re: [ANNOUNCE] Apache Flink Kubernetes Operator 1.0.1 released

Sorry for the incorrect blogpost link, please ignore that. There is no blogpbost for 1.0.1 :) Gyula On Tue, Jun 28, 2022 at 9:43 AM Yang Wang wrote: > Thanks Gyula for working on the first patch release for the Flink > Kubernetes Operator project. > > > Best, > Yang > > > > Gyula Fóra 于2022年6月

how to connect to the flink-state store and use it as cache to serve APIs.

Hi Team, I am not sure if this is the right use case for the state-store but I wanted to serve the APIs using queryable-state, what are the different ways to achieve this ? I have come across a version where we can use Job_Id to connect to the state, but is there any other way to expose a specific

Re: Synchronizing streams in coprocessfunction

On Mon, Jun 27, 2022 at 7:47 PM Schwalbe Matthias < matthias.schwa...@viseca.ch> wrote: > Hi Gopi, > > > > Your use case is a little under-specified to give a specific answer, > especially to the nature of the two input streams and the way events of > both streams are correlated (joined): > >-

Re: Reply：DelegationTokenManager

Hi, Gabor Somogyi! Because my fork repository from apache flink repository was outdated, i did't find in time that some subtasks about KerberosDelegationTokenManager had been done. I accomplished this feature on flink-1.13.5 release used in my scenario, and created a jira FLINK-28291 with p

Re: how to connect to the flink-state store and use it as cache to serve APIs.

Hi, laxmi. There are two ways that users can access the state store currently: 1. Queryable state [1] which you could access states in runtime. 2. State Processor API [2] which you could access states (snapshot) offline. But we have marked the Queryable state as "Reaching End-of-Life". We are also