Stack Overflow
Stack Overflow

Questions tagged [flink-stateful-functions]

8 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

Examining state in Flink Stateful Functions

Question I would like to be able to view the persisted state associated with function addresses in Flink Stateful Functions. What is the best option for achieving this? Details By "persisted state", I mean the data that StateFun passes to…
Gabriel Deal
  • 935
  • 1
  • 8
  • 19
0
votes
0 answers

Flink-statefun dynamic function discovery and fan-out execution

What would be a scalable way to dynamically register and call remote-statefun? I know I can register statefun while submitting a flink job but it's not ideal to submit a new build per new function. I wonder why would flink need to know about remote…
Shunya One
  • 1
  • 1
0
votes
0 answers

How do I do Multiple Window Aggregations in Apache Flink

We have millions of drivers earning tips. A driver can choose to get notified about their tips earned hourly, or every 6-hours, or every 12-hours, or daily. Essentially, we can have 4 time windows to aggregate driver tips by (1, 6, 12 and 24). A…
judi.miller
  • 3
  • 2
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
0 answers

How to read Kafka message header through Flink Stateful Functions in Python

Is it possible to read Kafka message header which is set in KafkaProducer application, in Flink Stateful function written in Python KafkaProducer looks like this Set
headers = Collections.singleton(new RecordHeader("is_mock_event",…
techlearner
  • 109
  • 1
  • 4
0
votes
1 answer

Is Flink KeyedStream sum() function stateful?

Let's write a simple wordcount job DataStream> counts = text.flatMap(new Tokenizer()) .keyBy(value -> value.f0) .sum(1); (source and other details are irrilevant) Suppose into the…
Vin
  • 701
  • 1
  • 9
  • 30
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