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…

Kaan Demirel
- 180
- 1
- 2
- 16
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…

aaa
- 5
- 2
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…

Rams
- 2,141
- 5
- 33
- 59