Hi,
I’m trying to work through an example with Flink Stateful Functions in Python.
I have a series of custom protobuf messages that I’ve defined but I’m
struggling with how they should be provided to the runtime so the messages in
Kafka can be deserialized. I see,
type: statefun.kafka.io/rou
Hi,
In doing some testing with Flink stateful functions in Python and I’ve gotten a
small POC working. One of our key requirements for our stream processors is
that they be written in python due to the skillset of our team. Given that the
Python DataStreams api seems to be under development i
?
Thanks,
Dan
From: "Tzu-Li (Gordon) Tai"
Date: Friday 9 October 2020 at 06:54
To: "Clements, Danial C"
Cc: user
Subject: Re: Native State in Python Stateful Functions?
Hi,
Nice to hear that you are trying out StateFun!
It is by design that function state is attached to
the Flink workers? How do you
know when you’ll need to add more instances?
Thanks,
Dan
From: "Tzu-Li (Gordon) Tai"
Date: Friday 9 October 2020 at 10:28
To: "Clements, Danial C"
Cc: user
Subject: Re: Native State in Python Stateful Functions?
Hi,
On Fri, Oct 9, 2020, 4:20 P
