This is an automated email from the ASF dual-hosted git repository. trohrmann pushed a commit to branch release-1.6 in repository https://gitbox.apache.org/repos/asf/flink.git
commit 5c4f9decc9a2213f1c8e63f06376e8dfc1ea90f9 Author: gyao <[email protected]> AuthorDate: Wed Aug 8 13:51:35 2018 +0200 [hotfix][tests] Remove unused argument from db/flink-db. --- flink-jepsen/src/jepsen/flink/db.clj | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/flink-jepsen/src/jepsen/flink/db.clj b/flink-jepsen/src/jepsen/flink/db.clj index 16952ef..becc551 100644 --- a/flink-jepsen/src/jepsen/flink/db.clj +++ b/flink-jepsen/src/jepsen/flink/db.clj @@ -97,7 +97,7 @@ (if (cu/exists? log-dir) (cu/ls-full log-dir) [])) (defn flink-db - [test] + [] (reify db/DB (setup! [_ test node] (c/su @@ -131,7 +131,7 @@ [] (let [zk (zk/db deb-zookeeper-package) hadoop (hadoop/db hadoop-dist-url) - flink (flink-db test)] + flink (flink-db)] (combined-db [hadoop zk flink]))) (defn exec-flink! @@ -192,7 +192,7 @@ (let [zk (zk/db deb-zookeeper-package) hadoop (hadoop/db hadoop-dist-url) mesos (mesos/db deb-mesos-package deb-marathon-package) - flink (flink-db test)] + flink (flink-db)] (combined-db [hadoop zk mesos flink]))) (defn submit-job-with-retry!
