Hi,
for development I used the memory backend. Now I switch to rocksdb backend and
have some questions:
1. Will all values (@Persisted) be loaded eagerly (on activation of the
function’s scope) or is there some kind of lazy loading?
2. If there is some kind of lazy loading:
*
Hi Gorden,
here is the link, if anyone else is also interested:
https://issues.apache.org/jira/browse/FLINK-21308
Cheers,
Stephan
Von: Tzu-Li (Gordon) Tai
Gesendet: Freitag, 5. Februar 2021 12:58
An: Stephan Pelikan
Cc: user@flink.apache.org; Igal Shilman
Betreff: Re: Statefun: cancel
a little bit into the code. May I create an issue to discuss my ideas?
Cheers,
Stephan
Von: Tzu-Li (Gordon) Tai
Gesendet: Mittwoch, 3. Februar 2021 07:58
An: Stephan Pelikan
Cc: user@flink.apache.org; Igal Shilman
Betreff: Re: Statefun: cancel "sendAfter"
Hi,
You are right,
Hi,
I think about using "sendAfter" to implement some kind of timer functionality.
I'm wondering if there is no possibility to cancel delayed sent message!
In my use case it is possible that intermediate events make the delayed message
obsolete. In some cases the statefun of that certain ID is
ay I would get historical data of states outdated or cleared.
This sounds like a feasible solution. What do you think?
Cheers,
Stephan
Von: Tzu-Li (Gordon) Tai
Gesendet: Donnerstag, 28. Jänner 2021 04:06
An: Stephan Pelikan
Cc: user@flink.apache.org
Betreff: Re: Stateful Functions - accessing
Hi,
We are trying to use Statefuns for our tool and it seems to be a good fit. I
already adopted it and it works quite well. However, we have millions of
different states (all the same FunctionType but different ids) and each state
consists of several @Persisted values (values and tables). We
rse it is not a
problem, I was just astonished.
Thanks,
Stephan
Von: Tzu-Li (Gordon) Tai
Gesendet: Dienstag, 12. Jänner 2021 10:07
An: Stephan Pelikan
Cc: user@flink.apache.org
Betreff: Re: Statefun with RabbitMQ consumes message but does not run statefun
Hi,
There is no lock-step of releasing a
with
the newest version of Statefun? I'm wondering why there is no Statefun version
matching the current stable version of Flink?
Stephan
Von: Stephan Pelikan
Gesendet: Montag, 11. Jänner 2021 19:37
An: user@flink.apache.org
Betreff: Statefun with RabbitMQ consumes message but does not run statefun
Hi,
I try to use RabbitMQ as a Source. My source consumes messages of the queue but
the statefun is not execution - not even created.
This is my main function:
1 public static void main(String[] args) throws Exception {
2
3 final var env =
