python (65.2k questions)

javascript (44.3k questions)

reactjs (22.7k questions)

java (20.8k questions)

c# (17.4k questions)

html (16.3k questions)

r (13.7k questions)

android (13k questions)

Questions - flink-statefun

Invoking Flink stateful function using REST API

I'm writing an Apache Flink Statefun application using python. I'm looking for help/pointers to invoke existing stateful function via a REST POST/GET call. I referred to https://github.com/apache/flin...
test-img

Himanshu

pyflink

flink-statefun

Votes: 0

Answers: 1

Latest Answer

Since Stateful Functions is a Flink job internally, it inherits Flink's ability to rewind the progress. When Flink restarts job processing from a checkpoint or a savepoint, it resets a source position...
test-img

Tymur Yarosh

Flink Statefun netty DisconnectedException

I am trying to run a flink statefun (version 3.2.0) application on my local machine using docker, with a single task manager and a single job manager. The application is a pipeline of multiple service...
test-img

justaq

docker

apache-flink

netty

flink-statefun

Votes: 0

Answers: 0

Is there a way to customise a Kafka Deserializer in Kafka Ingress of Flink stateful function?

In my project, I am going to use flink statefun kafka ingress for consuming avro-serialized records from kafka, but it seems there is no config parameter for users to specify the deserilizer for deser...
test-img

Xin Li

apache-flink

flink-statefun

Votes: 0

Answers: 0

Flink MapState with remote functions

So, I'm trying to implement flink's mapState using remote functions. In the mapState I'll be storing around 1000 values mapped with one key. Can someone point me in direction to implement it for remot...
test-img

Singh3y

apache-flink

flink-statefun

Votes: 0

Answers: 0

Posts

Questions

Blogs

Jobs