 
 (defn- default-flink-configuration
   [test node]
-  {:high-availability                  "zookeeper"
-   :high-availability.zookeeper.quorum (zookeeper-quorum test)
-   :high-availability.storageDir       "hdfs:///flink/ha"
-   :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.registration.timeout   "30 s"})
+  {: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]

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

(defn yarn-job-db
  []

  []
  (fu/join-space (hadoop-env-vars)
                 (str install-dir "/bin/yarn-session.sh")
                 "-d"))

(defn- start-yarn-session!
  []
