diff --git a/flink-jepsen/src/jepsen/flink/db.clj b/flink-jepsen/src/jepsen/flink/db.clj index 30f70843d4b7d..971c69e50005a 100644 --- a/flink-jepsen/src/jepsen/flink/db.clj +++ b/flink-jepsen/src/jepsen/flink/db.clj @@ -57,7 +57,7 @@ :taskmanager.numberOfTaskSlots taskmanager-slots :yarn.application-attempts 99999 :slotmanager.taskmanager-timeout 10000 - :state.backend.local-recovery "false" + :state.backend.local-recovery "true" :taskmanager.registration.timeout "30 s"}) (defn write-configuration!