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 812ac8b2a13bb71cf4e5859b245cf13dfddbd222 Author: gyao <[email protected]> AuthorDate: Wed Aug 8 14:02:39 2018 +0200 [FLINK-10063][tests] Set Marathon's maxLaunchDelaySeconds to 3. The default value for maxLaunchDelaySeconds is 3600 (1 hour). For testing purposes this value is too high and can cause false positive test failures. This closes #6496. --- flink-jepsen/src/jepsen/flink/db.clj | 37 ++++++++++++++++++------------------ 1 file changed, 19 insertions(+), 18 deletions(-) diff --git a/flink-jepsen/src/jepsen/flink/db.clj b/flink-jepsen/src/jepsen/flink/db.clj index 9a725d7..16952ef 100644 --- a/flink-jepsen/src/jepsen/flink/db.clj +++ b/flink-jepsen/src/jepsen/flink/db.clj @@ -209,24 +209,25 @@ (let [r (fu/retry (fn [] (http/post (str (mesos/marathon-base-url test) "/v2/apps") - {:form-params {:id "flink" - :cmd (str "HADOOP_CLASSPATH=`" hadoop/install-dir "/bin/hadoop classpath` " - "HADOOP_CONF_DIR=" hadoop/hadoop-conf-dir " " - install-dir "/bin/mesos-appmaster.sh " - "-Dmesos.master=" (zookeeper-uri - test - mesos/zk-namespace) " " - "-Djobmanager.rpc.address=$(hostname -f) " - "-Djobmanager.heap.mb=2048 " - "-Djobmanager.rpc.port=6123 " - "-Djobmanager.web.port=8081 " - "-Dmesos.resourcemanager.tasks.mem=2048 " - "-Dtaskmanager.heap.mb=2048 " - "-Dtaskmanager.numberOfTaskSlots=2 " - "-Dmesos.resourcemanager.tasks.cpus=1 " - "-Drest.bind-address=$(hostname -f) ") - :cpus 1.0 - :mem 2048} + {:form-params {:id "flink" + :cmd (str "HADOOP_CLASSPATH=`" hadoop/install-dir "/bin/hadoop classpath` " + "HADOOP_CONF_DIR=" hadoop/hadoop-conf-dir " " + install-dir "/bin/mesos-appmaster.sh " + "-Dmesos.master=" (zookeeper-uri + test + mesos/zk-namespace) " " + "-Djobmanager.rpc.address=$(hostname -f) " + "-Djobmanager.heap.mb=2048 " + "-Djobmanager.rpc.port=6123 " + "-Djobmanager.web.port=8081 " + "-Dmesos.resourcemanager.tasks.mem=2048 " + "-Dtaskmanager.heap.mb=2048 " + "-Dtaskmanager.numberOfTaskSlots=2 " + "-Dmesos.resourcemanager.tasks.cpus=1 " + "-Drest.bind-address=$(hostname -f) ") + :cpus 1.0 + :mem 2048 + :maxLaunchDelaySeconds 3} :content-type :json})))] (info "Submitted Flink Application via Marathon" r) (c/on (-> test :nodes sort first)
