[AT][QATM-1108] Update testsAT (apache#195)

pbedia-stratio · web-flow · commit 6a92d4be3b77 · 2018-04-26T14:10:25.000+02:00
diff --git a/Jenkinsfile b/Jenkinsfile
@@ -43,9 +43,11 @@ hose {
     INSTALLPARAMETERS = """
         | -DDCOS_CLI_HOST=%%DCOSCLI#0
         | -DDCOS_IP=10.200.0.156
-        | -DPEM_PATH=/paascerts/PaasIntegration.pem
+        | -DPEM_PATH=src/test/resources/credentials/PaasIntegration.pem
         | -DBOOTSTRAP_IP=10.200.0.155
         | -DSPARK_DOCKER_IMAGE=qa.stratio.com/stratio/stratio-spark
+        | -DSPARK_HISTORY_SERVER_DOCKER_IMAGE=qa.stratio.com/stratio/spark-stratio-history-server
+        | -DSPARK_DRIVER_DOCKER_IMAGE=qa.stratio.com/stratio/spark-stratio-driver
         | -DSTRATIO_SPARK_VERSION=%%VERSION
         | -DCLUSTER_ID=nightly
         | -DSPARK_COVERAGE_IMAGE=qa.stratio.com/stratio/stratio-spark-coverage
diff --git a/testsAT/src/test/resources/features/pf/coverage/elastic-coverage.feature b/testsAT/src/test/resources/features/pf/coverage/elastic-coverage.feature
@@ -20,7 +20,7 @@ Feature: [Spark Elastic Coverage] Elastic Coverage tests
     When I send a 'POST' request to '/service/${SPARK_FW_NAME}/v1/submissions/create' based on 'schemas/pf/SparkCoverage/elastic_curl.json' as 'json' with:
       |   $.appResource  |  UPDATE  | http://spark-coverage.marathon.mesos:9000/jobs/elastic-${COVERAGE_VERSION}.jar | n/a     |
       |   $.sparkProperties['spark.jars']  |  UPDATE  | http://spark-coverage.marathon.mesos:9000/jobs/elastic-${COVERAGE_VERSION}.jar | n/a     |
-      |   $.sparkProperties['spark.mesos.executor.docker.image']  |  UPDATE  | ${SPARK_DOCKER_IMAGE}:${STRATIO_SPARK_VERSION} | n/a     |
+      |   $.sparkProperties['spark.mesos.executor.docker.image']  |  UPDATE  | ${SPARK_DRIVER_DOCKER_IMAGE:-qa.stratio.com/stratio/spark-stratio-driver}:${STRATIO_SPARK_VERSION} | n/a     |
 
     Then the service response status must be '200' and its response must contain the text '"success" : true'
 
diff --git a/testsAT/src/test/resources/features/pf/coverage/hdfs-coverage.feature b/testsAT/src/test/resources/features/pf/coverage/hdfs-coverage.feature
@@ -20,7 +20,7 @@ Feature: [Spark HDFS Coverage] HDFS Coverage tests
     When I send a 'POST' request to '/service/${SPARK_FW_NAME}/v1/submissions/create' based on 'schemas/pf/SparkCoverage/hdfs_curl.json' as 'json' with:
       |   $.appResource  |  UPDATE  | http://spark-coverage.marathon.mesos:9000/jobs/hdfs-${COVERAGE_VERSION}.jar | n/a     |
       |   $.sparkProperties['spark.jars']  |  UPDATE  | http://spark-coverage.marathon.mesos:9000/jobs/hdfs-${COVERAGE_VERSION}.jar | n/a     |
-      |   $.sparkProperties['spark.mesos.executor.docker.image']  |  UPDATE  | ${SPARK_DOCKER_IMAGE}:${STRATIO_SPARK_VERSION} | n/a     |
+      |   $.sparkProperties['spark.mesos.executor.docker.image']  |  UPDATE  | ${SPARK_DRIVER_DOCKER_IMAGE:-qa.stratio.com/stratio/spark-stratio-driver}:${STRATIO_SPARK_VERSION} | n/a     |
       |   $.sparkProperties['spark.mesos.driverEnv.SPARK_SECURITY_HDFS_CONF_URI']  |  UPDATE  | http://spark-coverage.marathon.mesos:9000/configs/${CLUSTER_ID} | n/a     |
 
     Then the service response status must be '200' and its response must contain the text '"success" : true'
diff --git a/testsAT/src/test/resources/features/pf/coverage/install-spark-coverage.feature b/testsAT/src/test/resources/features/pf/coverage/install-spark-coverage.feature
@@ -6,7 +6,7 @@ Feature: [Install Spark Coverage] Installing Spark Coverage
 
   Scenario:[Spark dispatcher Installation][01] Installing Spark Coverage (for testing purposes)
     Given I create file 'SparkCoverage.json' based on 'schemas/pf/SparkCoverage/SparkCoverage.json' as 'json' with:
-      |   $.container.docker.image  |  UPDATE  | ${SPARK_COVERAGE_IMAGE}:${COVERAGE_VERSION} | n/a     |
+      |   $.container.docker.image  |  UPDATE  | ${SPARK_COVERAGE_IMAGE:-qa.stratio.com/stratio/stratio-spark-coverage}:${COVERAGE_VERSION} | n/a     |
 
     When I outbound copy 'target/test-classes/SparkCoverage.json' through a ssh connection to '/dcos'
 
diff --git a/testsAT/src/test/resources/features/pf/coverage/kafka-coverage.feature b/testsAT/src/test/resources/features/pf/coverage/kafka-coverage.feature
@@ -20,7 +20,7 @@ Feature: [Spark Kafka Coverage] Kafka Coverage tests
     When I send a 'POST' request to '/service/${SPARK_FW_NAME}/v1/submissions/create' based on 'schemas/pf/SparkCoverage/kafka_curl.json' as 'json' with:
       |   $.appResource  |  UPDATE  | http://spark-coverage.marathon.mesos:9000/jobs/kafka-${COVERAGE_VERSION}.jar | n/a     |
       |   $.sparkProperties['spark.jars']  |  UPDATE  | http://spark-coverage.marathon.mesos:9000/jobs/kafka-${COVERAGE_VERSION}.jar | n/a     |
-      |   $.sparkProperties['spark.mesos.executor.docker.image']  |  UPDATE  | ${SPARK_DOCKER_IMAGE}:${STRATIO_SPARK_VERSION} | n/a     |
+      |   $.sparkProperties['spark.mesos.executor.docker.image']  |  UPDATE  | ${SPARK_DRIVER_DOCKER_IMAGE:-qa.stratio.com/stratio/spark-stratio-driver}:${STRATIO_SPARK_VERSION} | n/a     |
       |   $.appArgs[0]  |  UPDATE  | gosec1.node.paas.labs.stratio.com:9092 | n/a     |
 
     Then the service response status must be '200' and its response must contain the text '"success" : true'
diff --git a/testsAT/src/test/resources/features/pf/coverage/postgres-coverage.feature b/testsAT/src/test/resources/features/pf/coverage/postgres-coverage.feature
@@ -30,7 +30,7 @@ Feature: [Spark Postgres Coverage] Postgres Coverage tests
     When I send a 'POST' request to '/service/${SPARK_FW_NAME}/v1/submissions/create' based on 'schemas/pf/SparkCoverage/postgres_curl.json' as 'json' with:
       |   $.appResource  |  UPDATE  | http://spark-coverage.marathon.mesos:9000/jobs/postgres-${COVERAGE_VERSION}.jar | n/a     |
       |   $.sparkProperties['spark.jars']  |  UPDATE  | http://spark-coverage.marathon.mesos:9000/jobs/postgres-${COVERAGE_VERSION}.jar | n/a     |
-      |   $.sparkProperties['spark.mesos.executor.docker.image']  |  UPDATE  | ${SPARK_DOCKER_IMAGE}:${STRATIO_SPARK_VERSION} | n/a     |
+      |   $.sparkProperties['spark.mesos.executor.docker.image']  |  UPDATE  | ${SPARK_DRIVER_DOCKER_IMAGE:-qa.stratio.com/stratio/spark-stratio-driver}:${STRATIO_SPARK_VERSION} | n/a     |
       |   $.appArgs[0]  |  UPDATE  | ${POSTGRES_INSTANCE} | n/a     |
 
     Then the service response status must be '200' and its response must contain the text '"success" : true'
diff --git a/testsAT/src/test/resources/features/pf/coverage/streaming-hdfs-dynamic.feature b/testsAT/src/test/resources/features/pf/coverage/streaming-hdfs-dynamic.feature
@@ -20,7 +20,7 @@ Feature: [HDFS Streaming HDFS Dynamic Coverage] Streaming HDFS Dynamic Coverage
     When I send a 'POST' request to '/service/${SPARK_FW_NAME}/v1/submissions/create' based on 'schemas/pf/SparkCoverage/streaming_hdfs_dynamic_curl.json' as 'json' with:
       |   $.appResource  |  UPDATE  | http://spark-coverage.marathon.mesos:9000/jobs/streaming-hdfs-dynamic-${COVERAGE_VERSION}.jar | n/a     |
       |   $.sparkProperties['spark.jars']  |  UPDATE  | http://spark-coverage.marathon.mesos:9000/jobs/streaming-hdfs-dynamic-${COVERAGE_VERSION}.jar | n/a     |
-      |   $.sparkProperties['spark.mesos.executor.docker.image']  |  UPDATE  | ${SPARK_DOCKER_IMAGE}:${STRATIO_SPARK_VERSION} | n/a     |
+      |   $.sparkProperties['spark.mesos.executor.docker.image']  |  UPDATE  | ${SPARK_DRIVER_DOCKER_IMAGE:-qa.stratio.com/stratio/spark-stratio-driver}:${STRATIO_SPARK_VERSION} | n/a     |
       |   $.sparkProperties['spark.mesos.driverEnv.SPARK_SECURITY_HDFS_CONF_URI']  |  UPDATE  | http://spark-coverage.marathon.mesos:9000/configs/${CLUSTER_ID} | n/a     |
 
     Then the service response status must be '200' and its response must contain the text '"success" : true'
diff --git a/testsAT/src/test/resources/features/pf/coverage/structured-streaming-coverage.feature b/testsAT/src/test/resources/features/pf/coverage/structured-streaming-coverage.feature
@@ -21,7 +21,7 @@ Feature: [HDFS Structured Streaming Coverage] Structured Streaming Coverage test
     When I send a 'POST' request to '/service/${SPARK_FW_NAME}/v1/submissions/create' based on 'schemas/pf/SparkCoverage/structured_streaming_curl.json' as 'json' with:
       |   $.appResource  |  UPDATE  | http://spark-coverage.marathon.mesos:9000/jobs/structured-streaming-${COVERAGE_VERSION}.jar | n/a     |
       |   $.sparkProperties['spark.jars']  |  UPDATE  | http://spark-coverage.marathon.mesos:9000/jobs/structured-streaming-${COVERAGE_VERSION}.jar | n/a     |
-      |   $.sparkProperties['spark.mesos.executor.docker.image']  |  UPDATE  | ${SPARK_DOCKER_IMAGE}:${STRATIO_SPARK_VERSION} | n/a     |
+      |   $.sparkProperties['spark.mesos.executor.docker.image']  |  UPDATE  | ${SPARK_DRIVER_DOCKER_IMAGE:-qa.stratio.com/stratio/spark-stratio-driver}:${STRATIO_SPARK_VERSION} | n/a     |
       |   $.appArgs[0]  |  UPDATE  | gosec1.node.paas.labs.stratio.com:9092 | n/a     |
 
     Then the service response status must be '200' and its response must contain the text '"success" : true'
diff --git a/testsAT/src/test/resources/features/pf/dispatcherAT/installation.feature b/testsAT/src/test/resources/features/pf/dispatcherAT/installation.feature
@@ -13,7 +13,7 @@ Feature: [Install Spark Dispatcher] Installing Spark Dispatcher
 
     #Start image from JSON
     And I run 'dcos package describe --app --options=/dcos/SparkDispatcherInstallation.json spark-dispatcher > /dcos/SparkDispatcherInstallationMarathon.json' in the ssh connection
-    And I run 'sed -i -e 's|"image":.*|"image": "${SPARK_DOCKER_IMAGE}:${STRATIO_SPARK_VERSION}",|g' /dcos/SparkDispatcherInstallationMarathon.json' in the ssh connection
+    And I run 'sed -i -e 's|"image":.*|"image": "${SPARK_DOCKER_IMAGE:-qa.stratio.com/stratio/stratio-spark}:${STRATIO_SPARK_VERSION}",|g' /dcos/SparkDispatcherInstallationMarathon.json' in the ssh connection
     And I run 'dcos marathon app add /dcos/SparkDispatcherInstallationMarathon.json' in the ssh connection
 
     #Check Spark-fw is Running
diff --git a/testsAT/src/test/resources/features/pf/historyServerAT/installation.feature b/testsAT/src/test/resources/features/pf/historyServerAT/installation.feature
@@ -14,7 +14,7 @@ Feature: [Install Spark History Server] Installing Spark History Server
 
         #Start image from JSON
         And I run 'dcos package describe --app --options=/dcos/SparkHistoryServerInstallation.json spark-history-server > /dcos/SparkHistoryServerInstallationMarathon.json' in the ssh connection
-        And I run 'sed -i -e 's|"image":.*|"image": "qa.stratio.com/stratio/spark-stratio-history-server:${STRATIO_SPARK_VERSION}",|g' /dcos/SparkHistoryServerInstallationMarathon.json' in the ssh connection
+        And I run 'sed -i -e 's|"image":.*|"image": "${SPARK_HISTORY_SERVER_DOCKER_IMAGE:-qa.stratio.com/stratio/spark-stratio-history-server}:${STRATIO_SPARK_VERSION}",|g' /dcos/SparkHistoryServerInstallationMarathon.json' in the ssh connection
         And I run 'dcos marathon app add /dcos/SparkHistoryServerInstallationMarathon.json' in the ssh connection
 
         #Check Spark-history-server is Running
diff --git a/testsAT/src/test/resources/features/pf/init/download-images.feature b/testsAT/src/test/resources/features/pf/init/download-images.feature
@@ -5,6 +5,6 @@ Feature: [Download Docker Images] Downloading images
     Given I open a ssh connection to '${DCOS_CLI_HOST}' with user 'root' and password 'stratio'
 
   Scenario:[Download images][01]Downloading docker images
-    Then I execute the command 'sudo docker pull ${SPARK_DOCKER_IMAGE}:${STRATIO_SPARK_VERSION}' in all the nodes of my cluster with user 'operador' and pem '${PEM_PATH}'
-    Then I execute the command 'sudo docker pull qa.stratio.com/stratio/spark-stratio-history-server:${STRATIO_SPARK_VERSION}' in all the nodes of my cluster with user 'operador' and pem '${PEM_PATH}'
-
+    Then I execute the command 'sudo docker pull ${SPARK_DOCKER_IMAGE:-qa.stratio.com/stratio/stratio-spark}:${STRATIO_SPARK_VERSION}' in all the nodes of my cluster with user 'operador' and pem '${PEM_PATH}'
+    Then I execute the command 'sudo docker pull ${SPARK_HISTORY_SERVER_DOCKER_IMAGE:-qa.stratio.com/stratio/spark-stratio-history-server}:${STRATIO_SPARK_VERSION}' in all the nodes of my cluster with user 'operador' and pem '${PEM_PATH}'
+    Then I execute the command 'sudo docker pull ${SPARK_DRIVER_DOCKER_IMAGE:-qa.stratio.com/stratio/spark-stratio-driver}:${STRATIO_SPARK_VERSION}' in all the nodes of my cluster with user 'operador' and pem '${PEM_PATH}'
diff --git a/testsAT/src/test/resources/features/pf/shuffle/installation.feature b/testsAT/src/test/resources/features/pf/shuffle/installation.feature
@@ -13,7 +13,7 @@ Feature: [Install Spark Shuffle] Installing Spark Shuffle
 
     #Start image from JSON
     And I run 'dcos package describe --app --options=/dcos/SparkShuffleInstallation.json spark-shuffle > /dcos/SparkShuffleInstallationMarathon.json' in the ssh connection
-    And I run 'sed -i -e 's|"image":.*|"image": "${SPARK_DOCKER_IMAGE}:${STRATIO_SPARK_VERSION}",|g' /dcos/SparkShuffleInstallationMarathon.json' in the ssh connection
+    And I run 'sed -i -e 's|"image":.*|"image": "${SPARK_DOCKER_IMAGE:-qa.stratio.com/stratio/stratio-spark}:${STRATIO_SPARK_VERSION}",|g' /dcos/SparkShuffleInstallationMarathon.json' in the ssh connection
     And I run 'dcos marathon app add /dcos/SparkShuffleInstallationMarathon.json' in the ssh connection
 
     #Wait 120 seconds to launch all the spark-shuffle instances (Download from docker image)
diff --git a/testsAT/src/test/resources/features/pnf/fault/dispatcher-dropsdown.feature b/testsAT/src/test/resources/features/pnf/fault/dispatcher-dropsdown.feature
@@ -24,7 +24,7 @@ Feature: [Fault Tolerance test] Dispatcher Dropdowns
     When I send a 'POST' request to '/service/${SPARK_FW_NAME}/v1/submissions/create' based on 'schemas/pf/SparkCoverage/kafka_curl.json' as 'json' with:
       |   $.appResource  |  UPDATE  | http://spark-coverage.marathon.mesos:9000/jobs/kafka-${COVERAGE_VERSION}.jar | n/a     |
       |   $.sparkProperties['spark.jars']  |  UPDATE  | http://spark-coverage.marathon.mesos:9000/jobs/kafka-${COVERAGE_VERSION}.jar | n/a     |
-      |   $.sparkProperties['spark.mesos.executor.docker.image']  |  UPDATE  | ${SPARK_DOCKER_IMAGE}:${STRATIO_SPARK_VERSION} | n/a     |
+      |   $.sparkProperties['spark.mesos.executor.docker.image']  |  UPDATE  | ${SPARK_DRIVER_DOCKER_IMAGE:-qa.stratio.com/stratio/spark-stratio-driver}:${STRATIO_SPARK_VERSION} | n/a     |
       |   $.appArgs[0]  |  UPDATE  | gosec1.node.paas.labs.stratio.com:9092 | n/a     |
 
     Then the service response status must be '200' and its response must contain the text '"success" : true'
@@ -53,7 +53,7 @@ Feature: [Fault Tolerance test] Dispatcher Dropdowns
 
     #Start image from JSON
     And I run 'dcos package describe --app --options=/dcos/SparkDispatcherInstallation.json spark-dispatcher > /dcos/SparkDispatcherInstallationMarathon.json' in the ssh connection
-    And I run 'sed -i -e 's|"image":.*|"image": "${SPARK_DOCKER_IMAGE}:${STRATIO_SPARK_VERSION}",|g' /dcos/SparkDispatcherInstallationMarathon.json' in the ssh connection
+    And I run 'sed -i -e 's|"image":.*|"image": "${SPARK_DOCKER_IMAGE:-qa.stratio.com/stratio/stratio-spark}:${STRATIO_SPARK_VERSION}",|g' /dcos/SparkDispatcherInstallationMarathon.json' in the ssh connection
     And I run 'dcos marathon app add /dcos/SparkDispatcherInstallationMarathon.json' in the ssh connection
 
     #Check Spark-fw is Running
diff --git a/testsAT/src/test/resources/features/pnf/fault/driver-supervise-false.feature b/testsAT/src/test/resources/features/pnf/fault/driver-supervise-false.feature
@@ -24,7 +24,7 @@ Feature: [Fault Tolerance test] Driver supervise false
     When I send a 'POST' request to '/service/${SPARK_FW_NAME}/v1/submissions/create' based on 'schemas/pf/SparkCoverage/kafka_curl.json' as 'json' with:
       |   $.appResource  |  UPDATE  | http://spark-coverage.marathon.mesos:9000/jobs/kafka-${COVERAGE_VERSION}.jar | n/a     |
       |   $.sparkProperties['spark.jars']  |  UPDATE  | http://spark-coverage.marathon.mesos:9000/jobs/kafka-${COVERAGE_VERSION}.jar | n/a     |
-      |   $.sparkProperties['spark.mesos.executor.docker.image']  |  UPDATE  | ${SPARK_DOCKER_IMAGE}:${STRATIO_SPARK_VERSION} | n/a     |
+      |   $.sparkProperties['spark.mesos.executor.docker.image']  |  UPDATE  | ${SPARK_DRIVER_DOCKER_IMAGE:-qa.stratio.com/stratio/spark-stratio-driver}:${STRATIO_SPARK_VERSION} | n/a     |
       |   $.appArgs[0]  |  UPDATE  | gosec1.node.paas.labs.stratio.com:9092 | n/a     |
 
     Then the service response status must be '200' and its response must contain the text '"success" : true'
@@ -44,7 +44,7 @@ Feature: [Fault Tolerance test] Driver supervise false
     Then I open a ssh connection to '!{DRIVER_IP}' with user 'root' and password 'stratio'
 
     #Wait first for having a running docker and rm them
-    Then I run 'docker ps | grep ${SPARK_DOCKER_IMAGE}:${STRATIO_SPARK_VERSION} | cut -d ' ' -f 1 | while read x; do cmd=$(docker inspect $x | jq '.[]|.Args'); echo $x $cmd; done | grep -m 1 "/bin/spark-submit" | cut -d ' ' -f 1' in the ssh connection and save the value in environment variable 'DOCKER_ID'
+    Then I run 'docker ps | grep ${SPARK_DRIVER_DOCKER_IMAGE:-qa.stratio.com/stratio/spark-stratio-driver}:${STRATIO_SPARK_VERSION} | cut -d ' ' -f 1 | while read x; do cmd=$(docker inspect $x | jq '.[]|.Args'); echo $x $cmd; done | grep -m 1 "/bin/spark-submit" | cut -d ' ' -f 1' in the ssh connection and save the value in environment variable 'DOCKER_ID'
     Then I run 'docker rm -f !{DOCKER_ID}' in the ssh connection
 
     #Check the driver is killed (not relaunched)
diff --git a/testsAT/src/test/resources/features/pnf/fault/executors-dropsdown.feature b/testsAT/src/test/resources/features/pnf/fault/executors-dropsdown.feature
@@ -24,7 +24,7 @@ Feature: [Fault Tolerance test] Executor Dropdowns
     When I send a 'POST' request to '/service/${SPARK_FW_NAME}/v1/submissions/create' based on 'schemas/pf/SparkCoverage/kafka_curl.json' as 'json' with:
       |   $.appResource  |  UPDATE  | http://spark-coverage.marathon.mesos:9000/jobs/kafka-${COVERAGE_VERSION}.jar | n/a     |
       |   $.sparkProperties['spark.jars']  |  UPDATE  | http://spark-coverage.marathon.mesos:9000/jobs/kafka-${COVERAGE_VERSION}.jar | n/a     |
-      |   $.sparkProperties['spark.mesos.executor.docker.image']  |  UPDATE  | ${SPARK_DOCKER_IMAGE}:${STRATIO_SPARK_VERSION} | n/a     |
+      |   $.sparkProperties['spark.mesos.executor.docker.image']  |  UPDATE  | ${SPARK_DRIVER_DOCKER_IMAGE:-qa.stratio.com/stratio/spark-stratio-driver}:${STRATIO_SPARK_VERSION} | n/a     |
       |   $.appArgs[0]  |  UPDATE  | gosec1.node.paas.labs.stratio.com:9092 | n/a     |
 
     Then the service response status must be '200' and its response must contain the text '"success" : true'
@@ -44,7 +44,7 @@ Feature: [Fault Tolerance test] Executor Dropdowns
     Then I open a ssh connection to '!{EXECUTOR_IP}' with user 'root' and password 'stratio'
 
     #Wait first for having a running docker
-    Then I run 'docker ps | grep ${SPARK_DOCKER_IMAGE}:${STRATIO_SPARK_VERSION} | cut -d ' ' -f 1 | while read x; do cmd=$(docker inspect $x | jq '.[]|.Args'); echo $x $cmd; done | grep org.apache.spark.executor.CoarseGrainedExecutorBackend | cut -d ' ' -f 1' in the ssh connection and save the value in environment variable 'DOCKER_ID'
+    Then I run 'docker ps | grep ${SPARK_DRIVER_DOCKER_IMAGE:-qa.stratio.com/stratio/spark-stratio-driver}:${STRATIO_SPARK_VERSION} | cut -d ' ' -f 1 | while read x; do cmd=$(docker inspect $x | jq '.[]|.Args'); echo $x $cmd; done | grep org.apache.spark.executor.CoarseGrainedExecutorBackend | cut -d ' ' -f 1' in the ssh connection and save the value in environment variable 'DOCKER_ID'
     Then I run 'docker rm -f !{DOCKER_ID}' in the ssh connection
 
     #Check there are a TASK_FAILED (killed by us)
diff --git a/testsAT/src/test/resources/features/pnf/performance/performance-test.feature b/testsAT/src/test/resources/features/pnf/performance/performance-test.feature
@@ -42,7 +42,7 @@ Feature: [Spark Performance Tests] Spark performance tests
       |   $.appArgs[3]  |  UPDATE  | /tmp | n/a     |
       |   $.appResource  |  UPDATE  | http://spark-coverage.marathon.mesos:9000/jobs/tpcds-queries-${COVERAGE_VERSION}.jar | n/a     |
       |   $.sparkProperties['spark.jars']  |  UPDATE  | http://spark-coverage.marathon.mesos:9000/jobs/tpcds-queries-${COVERAGE_VERSION}.jar | n/a     |
-      |   $.sparkProperties['spark.mesos.executor.docker.image']  |  UPDATE  | ${SPARK_DOCKER_IMAGE}:${STRATIO_SPARK_VERSION} | n/a     |
+      |   $.sparkProperties['spark.mesos.executor.docker.image']  |  UPDATE  | ${SPARK_DRIVER_DOCKER_IMAGE:-qa.stratio.com/stratio/spark-stratio-driver}:${STRATIO_SPARK_VERSION} | n/a     |
       |   $.sparkProperties['spark.mesos.driverEnv.SPARK_SECURITY_HDFS_CONF_URI']  |  UPDATE  | http://spark-coverage.marathon.mesos:9000/configs/${CLUSTER_ID} | n/a     |
       |   $.sparkProperties['spark.executor.cores']  |  UPDATE  | !{CORES_PER_EXECUTOR} | n/a     |
       |   $.sparkProperties['spark.cores.max']  |  UPDATE  | !{CORES} | n/a     |
diff --git a/testsAT/src/test/resources/schemas/pf/SparkCoverage/SparkCoverage.json b/testsAT/src/test/resources/schemas/pf/SparkCoverage/SparkCoverage.json
@@ -19,7 +19,7 @@
   "maxLaunchDelaySeconds": 3600,
   "container": {
     "docker": {
-      "image": "qa.stratio.com/stratio/stratio-spark-coverage:0.1.0-SNAPSHOT",
+      "image": "qa.stratio.com/stratio/stratio-spark-coverage:0.2.0-SNAPSHOT",
       "forcePullImage": true,
       "privileged": false,
       "network": "HOST"
diff --git a/testsAT/src/test/resources/schemas/pf/SparkCoverage/elastic_curl.json b/testsAT/src/test/resources/schemas/pf/SparkCoverage/elastic_curl.json
@@ -10,7 +10,7 @@
   "sparkProperties": {
     "spark.jars": "$ES_JAR_URL",
     "spark.app.name": "AT-elasticsearch",
-    "spark.mesos.executor.docker.image": "$SPARK_DOCKER_IMAGE",
+    "spark.mesos.executor.docker.image": "$SPARK_DRIVER_DOCKER_IMAGE",
     "spark.mesos.executor.docker.volumes": "/etc/pki/ca-trust/extracted/java/cacerts/:/usr/lib/jvm/jre1.8.0_112/lib/security/cacerts:ro,/etc/resolv.conf:/etc/resolv.conf:ro",
     "spark.driver.supervise": "false",
     "spark.secret.vault.role": "open",
diff --git a/testsAT/src/test/resources/schemas/pf/SparkCoverage/hdfs_curl.json b/testsAT/src/test/resources/schemas/pf/SparkCoverage/hdfs_curl.json
@@ -10,7 +10,7 @@
   "sparkProperties": {
     "spark.jars": "$HDFS_JAR_URL",
     "spark.app.name": "AT-hdfs",
-    "spark.mesos.executor.docker.image": "$SPARK_DOCKER_IMAGE",
+    "spark.mesos.executor.docker.image": "$SPARK_DRIVER_DOCKER_IMAGE",
     "spark.mesos.executor.docker.volumes": "/etc/pki/ca-trust/extracted/java/cacerts/:/usr/lib/jvm/jre1.8.0_112/lib/security/cacerts:ro,/etc/resolv.conf:/etc/resolv.conf:ro",
     "spark.driver.supervise": "false",
     "spark.secret.vault.role": "open",
diff --git a/testsAT/src/test/resources/schemas/pf/SparkCoverage/kafka_curl.json b/testsAT/src/test/resources/schemas/pf/SparkCoverage/kafka_curl.json
diff --git a/testsAT/src/test/resources/schemas/pf/SparkCoverage/postgres_curl.json b/testsAT/src/test/resources/schemas/pf/SparkCoverage/postgres_curl.json
diff --git a/testsAT/src/test/resources/schemas/pf/SparkCoverage/streaming_hdfs_dynamic_curl.json b/testsAT/src/test/resources/schemas/pf/SparkCoverage/streaming_hdfs_dynamic_curl.json
diff --git a/testsAT/src/test/resources/schemas/pf/SparkCoverage/structured_streaming_curl.json b/testsAT/src/test/resources/schemas/pf/SparkCoverage/structured_streaming_curl.json
diff --git a/testsAT/src/test/resources/schemas/pf/SparkDispatcher/BasicSparkDispatcher.json b/testsAT/src/test/resources/schemas/pf/SparkDispatcher/BasicSparkDispatcher.json
diff --git a/testsAT/src/test/resources/schemas/pf/SparkHistoryServer/BasicSparkHistoryServer.json b/testsAT/src/test/resources/schemas/pf/SparkHistoryServer/BasicSparkHistoryServer.json
diff --git a/testsAT/src/test/resources/schemas/pnf/performance/tpcds_curl.json b/testsAT/src/test/resources/schemas/pnf/performance/tpcds_curl.json
diff --git a/testsAT/testng.xml b/testsAT/testng.xml
