Solved it, and posting here in case anyone run into the same issue!
Since the Harness uses StreamExecutionEnvironment to set the flink configurations, you have to set the state backend explicitly, as described here: <file:///tmp/checkpoints>https://github.com/apache/flink/blob/master/flink-state-backends/flink-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 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 the regular Flink including the rocksdb state backend be included as a dependency? Since I am a bit confused about the layout, if someone could provide a description of how the StateFun project relates to the Flink codebase, and how one can work effectively with these two in an IDE would be very appreciated. Thanks, Christopher
