Hi Christian,

I assume you're using the rocksdb state backend. You can enable some
metrics from Rocksdb, please refer to the doc[1].
Please note that the `State#clear` only removes the key/value for
specified key, rather than removing all keys. And the deletion will be
reflected in the checkpoint after the rocksdb compaction.

[1]
https://nightlies.apache.org/flink/flink-docs-master/docs/deployment/config/#rocksdb-native-metrics


Best,
Zakelly

On Mon, Dec 2, 2024 at 9:18 PM Christian Lorenz via user <
user@flink.apache.org> wrote:

> Hi,
>
>
>
> is there a way to receive some basic statistics of a named value-state in
> flink?
>
> Besides, is the assumption correct that a call to
> org.apache.flink.api.common.state.State#clear is removing the state also
> from the checkpoint data? We had to use some long TTL time and am uncertain
> if the data is really cleaned up before the TTL of the state is reached.
>
>
>
> Thanks and kind regards,
>
> Christian
>
> Mapp Digital Germany GmbH with registered offices at Schönhauser Allee
> 148, 10435 Berlin.
> Registered with the District Court München HRB 226181
> Managing Directors: Frasier, Christopher & Warren, Steve
>
> This e-mail is from Mapp Digital Group and its international legal
> entities and may contain information that is confidential.
> If you are not the intended recipient, do not read, copy or distribute the
> e-mail or any attachments. Instead, please notify the sender and delete the
> e-mail and any attachments.
>

Reply via email to