ilililil
10/15/2025, 4:19 AMfinal var stateFuture = state.asyncValue();
stateFuture.thenAccept(value -> {
ctx.timerService().registerEventTimeTimer(timestamp + someValue);
out.collect(foo(value));
});Zakelly
10/15/2025, 4:41 AMilililil
10/15/2025, 4:42 AMZakelly
10/15/2025, 4:44 AMZakelly
10/15/2025, 4:44 AMprocessElement, flatMap or thenXXxx methods following the state access methods will be executed in a single thread (the task thread). So there is no concurrency issue for the user code."ilililil
10/15/2025, 4:45 AM