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
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
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):
>
>-
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
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月
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
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
