search

cda-group / arcon

State-first Streaming Applications in Rust
https://cda-group.github.io/arcon/
Apache License 2.0
175 stars 17 forks source link

Timer Timeout Missing Key Context #300

Closed Max-Meldrum closed 2 years ago

Max-Meldrum commented 2 years ago

When handling timeouts, we need to also get back the key used so that we can set up the OperatorContext properly. Things may go very wrong now if timers or state calls are used within handle_timeout.

 fn handle_timeout(
    &mut self,
    timeout: Self::TimerState,
    ctx: &mut OperatorContext<Self::TimerState, Self::OperatorState>,
 ) -> ArconResult<Option<Self::ElementIterator>>;