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.
statefun.embedded
false Boolean Set to 'true' if Flink is running this job from an uber jar, rather than using statefun-specific docker images. This disables the validation of whether 'classloader.parent-first-patterns.additional' contains 'org.apache.flink.statefun', 'org.apache.kafka' and 'com.google.protobuf' patterns. It is then up to the creator of the uber jar to ensure that the three dependencies (statefun, kafka and protobuf) don't have version conflicts.