Hi, thank you Gordon for clarification. My use-case is processing business events of customers. Those events are triggered by ourself or by the customer depending of what’s the current state of the ongoing customer’s business use-case. We need to monitor delayed/missing business events which belong to previous events. For example: the customer has to confirm something we did. Depending on what it is the confirmation has to be within hours, days or even months. If there is a delay we need to know. But if the customer confirms in time we want to cleanup to keep the state small.
I dug a little bit into the code. May I create an issue to discuss my ideas? Cheers, Stephan Von: Tzu-Li (Gordon) Tai <tzuli...@apache.org> Gesendet: Mittwoch, 3. Februar 2021 07:58 An: Stephan Pelikan <stephan.peli...@phactum.at> Cc: user@flink.apache.org; Igal Shilman <i...@ververica.com> Betreff: Re: Statefun: cancel "sendAfter" Hi, You are right, currently StateFun does not support deleting a scheduled delayed message. StateFun supports delayed messages by building on top of two Flink constructs: 1) registering processing time timers, and 2) buffering the message payload to be sent in state. The delayed messages are kept in the Flink state of the sending operator, and timers are registered on the sending operator as well. So technically, there doesn't seem to be a blocker for deleting a delayed message and its associated timer, if it hasn't been sent yet. Can you maybe open a JIRA ticket for this, so we have something that tracks it? Also cc'ing Igal, who might have more comments on whether supporting this makes sense. Cheers, Gordon On Wed, Feb 3, 2021 at 3:51 AM Stephan Pelikan <stephan.peli...@phactum.at<mailto:stephan.peli...@phactum.at>> wrote: 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 cleared (clear all state variables) and does not exist anymore. In other cases the statefun of that ID still exists (and its state). In the latter case I could ignore the delayed message, but what about those statefun which do not exist anymore? Additionally there can be millions of delayed messages which I do not need any more and some delays are also hours, days or even months. I don’t want to pollute my state with this because it will inflate the size of my checkpoints. There are no hints in the docs (https://ci.apache.org/projects/flink/flink-statefun-docs-release-2.2/sdk/java.html#sending-delayed-messages) how those situations are treated. I found in the Flink’s docs that timers of keyed processors can be deleted. As far as I know statefuns are based on those processors, so I hope that there is something about it. I hope someone can clarify what I can expect and how those situations are handled internally. Thanks, Stephan
