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/12/10 11:03:08 UTC

[flink] 06/06: [hotfix] Rename keys-as-allowed-values-help-text to keys->allowed-values-help-text

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 a6a2ffd0724b481dad2c894a50765c2c2d281d61
Author: Gary Yao <ga...@data-artisans.com>
AuthorDate: Mon Nov 26 12:04:09 2018 +0100

    [hotfix] Rename keys-as-allowed-values-help-text to keys->allowed-values-help-text
---
 flink-jepsen/src/jepsen/flink/flink.clj | 12 ++++++------
 1 file changed, 6 insertions(+), 6 deletions(-)

diff --git a/flink-jepsen/src/jepsen/flink/flink.clj b/flink-jepsen/src/jepsen/flink/flink.clj
index 70b79a1..a3698ab 100644
--- a/flink-jepsen/src/jepsen/flink/flink.clj
+++ b/flink-jepsen/src/jepsen/flink/flink.clj
@@ -98,7 +98,7 @@
             :checker   (flink-checker/job-running-checker)})
          (assoc opts :concurrency 1)))
 
-(defn keys-as-allowed-values-help-text
+(defn- keys->allowed-values-help-text
   "Takes a map and returns a string explaining which values are allowed.
   This is a CLI helper function."
   [m]
@@ -121,20 +121,20 @@
          :opt-spec [[nil "--test-spec FILE" "Path to a test specification (.edn)"
                      :parse-fn read-test-spec
                      :validate [#(->> % :dbs (map dbs) (every? (complement nil?)))
-                                (str "Invalid :dbs specification. " (keys-as-allowed-values-help-text dbs))]]
+                                (str "Invalid :dbs specification. " (keys->allowed-values-help-text dbs))]]
                     [nil "--ha-storage-dir DIR" "high-availability.storageDir"]
                     [nil "--nemesis-gen GEN" (str "Which nemesis should be used?"
-                                                  (keys-as-allowed-values-help-text fn/nemesis-generator-factories))
+                                                  (keys->allowed-values-help-text fn/nemesis-generator-factories))
                      :parse-fn keyword
                      :default :kill-task-managers
                      :validate [#(fn/nemesis-generator-factories %)
-                                (keys-as-allowed-values-help-text fn/nemesis-generator-factories)]]
+                                (keys->allowed-values-help-text fn/nemesis-generator-factories)]]
                     [nil "--client-gen GEN" (str "Which client should be used?"
-                                                 (keys-as-allowed-values-help-text client-gens))
+                                                 (keys->allowed-values-help-text client-gens))
                      :parse-fn keyword
                      :default :poll-job-running
                      :validate [#(client-gens %)
-                                (keys-as-allowed-values-help-text client-gens)]]
+                                (keys->allowed-values-help-text client-gens)]]
                     [nil "--job-running-healthy-threshold TIMES" "Number of consecutive times the job must be running to be considered healthy."
                      :default 5
                      :parse-fn #(Long/parseLong %)