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. |