Large backpressure and slow checkpoints in StateFun

iated. Best Regards, Christopher Gustafson

SV: SV: How to enable statefun metrics for the Slf4j reporter

Oh sorry no I was only looking at the JobManager logs, now I found them, thanks! Från: Chesnay Schepler Skickat: den 23 maj 2022 15:29:45 Till: Christopher Gustafson; user@flink.apache.org Ämne: Re: SV: How to enable statefun metrics for the Slf4j reporter Just

SV: How to enable statefun metrics for the Slf4j reporter

Yes, Flink metrics are showing up as usual, but none of the ones that are listed in the StateFun documentation. Från: Chesnay Schepler Skickat: den 23 maj 2022 14:29:15 Till: Christopher Gustafson; user@flink.apache.org Ämne: Re: How to enable statefun metrics

How to enable statefun metrics for the Slf4j reporter

any of the StateFun specific metrics in the logs. Best Regards, Christopher Gustafson

Protobuf ClassNotFound for Embedded Module

, but flink is not able to find them anyhow. Any idea of what I could be doing wrong? Best Regards, Christopher Gustafson

Adding a custom Kafka deserializer to Statefun Job

f doing so? Best Regards, Christopher Gustafson

SV: Checkpointing in StateFun

nt me to where I can see how Raw state can be used in Flink? Best Regards, Christopher Gustafson Från: Seth Wiesman Skickat: den 11 mars 2022 17:57:21 Till: Christopher Gustafson Kopia: user@flink.apache.org Ämne: Re: Checkpointing in StateFun I assume yo

Checkpointing in StateFun

not find a lot of documentation about this, so I am asking if you could provide a description of how checkpointing works in StateFun, and how it is different from regular Flink checkpointing? Thanks in advance, Christopher Gustafson

SV: Changing StateBackend for Statefun Harness E2E tests

-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBStateBackend.java#L59 All the best Från: Christopher Gustafson Skickat: den 9 februari 2022 13:34:05 Till: user@flink.apache.org Ämne: Changing StateBackend for Statefun Harness E2E tests

Changing StateBackend for Statefun Harness E2E tests

Hi everyone, I am looking into the code of StateFun, trying to understand how it works. I was trying to run the Harness E2E in my IDE, and tried to change the StateBackend to rocksdb, at which point I got an error saying it wasn't found. My first question then becomes, why is this? Shouldn't t

StateFun NoSuchMethodError when deploying to existing Cluster

Hi! I am having continued issues running a StateFun job in an existing Flink Cluster. My Flink cluster is using Flink version 1.14.3 and the StateFun job is using version 3.2.0 of the java SDK and statefun distribution. I get the following error: Caused by: java.lang.NoSuchMethodError: org.

AbstractMethodError when running StateFun job as jar

Hi everyone, I am trying to run a StateFun job as a jar in an existing cluster. But I run into a large error which is caused by the following: Caused by: java.lang.AbstractMethodError: Method org/apache/flink/statefun/flink/core/functions/FunctionGroupDispatchFactory .setMailboxExecutor(Lorg/ap

SV: StateFun deployement options

s but haven't succeeded in deploying it. Best, Christopher Från: Igal Shilman Skickat: den 1 februari 2022 12:26:52 Till: Christopher Gustafson Kopia: user@flink.apache.org Ämne: Re: StateFun deployement options Hello Christopher, The most common deployment o

StateFun deployement options

ons/packaging.html> but not in the latest versions. Is this way of deploying StateFun jobs still supported, and in that case are there any additional steps that has to be taken? Best Regards, Christopher Gustafson