You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ga...@apache.org on 2018/09/28 19:06:33 UTC
[flink] 07/10: [hotfix][tests] Reformat code in nemesis.clj
This is an automated email from the ASF dual-hosted git repository.
gary pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 565142389a309f006a248685df9f8a6ef8692388
Author: gyao <ga...@data-artisans.com>
AuthorDate: Tue Sep 18 08:14:25 2018 +0200
[hotfix][tests] Reformat code in nemesis.clj
---
flink-jepsen/src/jepsen/flink/nemesis.clj | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git a/flink-jepsen/src/jepsen/flink/nemesis.clj b/flink-jepsen/src/jepsen/flink/nemesis.clj
index 5335b24..5335bba 100644
--- a/flink-jepsen/src/jepsen/flink/nemesis.clj
+++ b/flink-jepsen/src/jepsen/flink/nemesis.clj
@@ -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
[]