Questions tagged [apache-stateful-functions]

3 questions
3
votes
1 answer

Flink Stateful Functions - unreliable behavior in org.apache.flink.statefun.sdk.Context::sendAfter

We developed a timeout like mechanism with SF (Stateful Functions) where we have a TimeoutManagerFunction which keeps and manages a state of current timeouts set by other functions and sends back an expiration message when it times out. To achieve…
0
votes
0 answers

Stateful Functions Java Custom Type Protobuf

I’m trying to setup a Protobuf custom type for Java and I noticed that the Python SDK features a “make_protobuf_type” function where you call it to make that Protofile a custom type for stateful functions. What would be the Java equivalent in this…
0
votes
1 answer

Apache Flink + StateFul functions + Sprint boot -ProgramInvocationException:

I'm pretty new to Apache flink and stateful functions just trying some code. I created a simple stateful greeting application using spring boot and included all necessary dependencies, created a fat jar. I'm trying to run this jar on flink…