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<KEY>
(none) String Adds the given key/value pair to the Stateful Functions global configuration.
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.
(none) String The custom payload serializer class to use with the WITH_CUSTOM_PAYLOADS serializer, which must implement MessagePayloadSerializer.
StatefulFunctions String The name to display in the Flink-UI.
32 MB Memory The number of bytes to use for in memory buffering of the feedback channel, before spilling to disk.
1024 Integer The max number of async operations per task before backpressure is applied.