You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2018/08/09 08:04:18 UTC
[flink] 03/03: [hotfix][tests] Remove unused argument from
db/flink-db.
This is an automated email from the ASF dual-hosted git repository.
trohrmann pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 4131ae4ec30d703fd374dd4c6ad293164bf10bd5
Author: gyao <ga...@data-artisans.com>
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!