 (defn- start-yarn-job!
   [test]
   (c/su
-    (submit-job-with-retry! test ["-m yarn-cluster" "-yjm 2048m" "-ytm 2048m"])))
+    (submit-job-with-retry! test ["-m yarn-cluster"])))
 
 (defn yarn-job-db
   []

    (str install-dir "/bin/mesos-appmaster.sh")
    (str "-Dmesos.master=" (zookeeper-uri test mesos/zk-namespace))
    "-Djobmanager.rpc.address=$(hostname -f)"
    "-Djobmanager.heap.size=2048m"
    "-Djobmanager.rpc.port=6123"
    "-Dmesos.resourcemanager.tasks.mem=2048"
    "-Dtaskmanager.memory.total-process.size=2048m"
    "-Dmesos.resourcemanager.tasks.cpus=1"
    "-Drest.bind-address=$(hostname -f)"))

(defn- start-mesos-session!


(defn- default-flink-configuration
  [test node]
  {:high-availability                     "zookeeper"
   :high-availability.zookeeper.quorum    (zookeeper-quorum test)
   :high-availability.storageDir          "hdfs:///flink/ha"
   :jobmanager.heap.size                  "2048m"
   :jobmanager.rpc.address                node
   :state.savepoints.dir                  "hdfs:///flink/savepoints"
   :rest.address                          node
   :rest.port                             8081
   :rest.bind-address                     "0.0.0.0"
   :taskmanager.numberOfTaskSlots         taskmanager-slots
   :yarn.application-attempts             99999
   :slotmanager.taskmanager-timeout       10000
   :state.backend.local-recovery          "true"
   :taskmanager.memory.total-process.size "2048m"
   :taskmanager.registration.timeout      "30 s"})

(defn flink-configuration
  [test node]
