Configurations
This documentation is for an unreleased version of Apache Flink Stateful Functions. We recommend you use the latest stable version.

Configurations #

Stateful Functions includes a small number of SDK specific configurations. These may be set through your job’s flink-conf.yaml.

Key Default Type Description
statefun.module.global-config.<KEY>
(none) String Adds the given key/value pair to the Stateful Functions global configuration.
statefun.message.serializer
WITH_PROTOBUF_PAYLOADS Message Serializer The serializer to use for on the wire messages. Options are WITH_PROTOBUF_PAYLOADS, WITH_KRYO_PAYLOADS, WITH_RAW_PAYLOADS, WITH_CUSTOM_PAYLOADS.
statefun.message.custom-payload-serializer-class
(none) String The custom payload serializer class to use with the WITH_CUSTOM_PAYLOADS serializer, which must implement MessagePayloadSerializer.
statefun.flink-job-name
StatefulFunctions String The name to display in the Flink-UI.
statefun.feedback.memory.size
32 MB Memory The number of bytes to use for in memory buffering of the feedback channel, before spilling to disk.
statefun.async.max-per-task
1024 Integer The max number of async operations per task before backpressure is applied.