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 a8d2f904df2d607c934b4f3a4f17c35e12d6b48b 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)
