Skip to content

Commit

Permalink
[hotfix][tests] Reformat code in nemesis.clj
Browse files Browse the repository at this point in the history
  • Loading branch information
GJL committed Sep 28, 2018
1 parent bfba2d2 commit 5651423
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions flink-jepsen/src/jepsen/flink/nemesis.clj
Original file line number Diff line number Diff line change
Expand Up @@ -130,14 +130,14 @@
(defn kill-taskmanagers-bursts-gen
[time-limit]
(fgen/time-limit time-limit
(gen/seq (cycle (concat (repeat 20 {:type :info, :f :kill-task-managers})
[(gen/sleep 300)])))))
(gen/seq (cycle (concat (repeat 20 {:type :info, :f :kill-task-managers})
[(gen/sleep 300)])))))

(defn kill-jobmanagers-gen
[time-limit]
(fgen/time-limit (+ time-limit job-submit-grace-period)
(gen/seq (cons (gen/sleep job-submit-grace-period)
(cycle [{:type :info, :f :kill-job-manager}])))))
(gen/seq (cons (gen/sleep job-submit-grace-period)
(cycle [{:type :info, :f :kill-job-manager}])))))

(defn fail-name-node-during-recovery
[]
Expand Down

0 comments on commit 5651423

Please sign in to comment.