Enhancement 436

src/main/scala/mesosphere/mesos/TaskBuilder.scala

@@ -189,6 +189,7 @@ object TaskBuilder {
       val uriProtos = app.uris.map(uri => {
         CommandInfo.URI.newBuilder()
           .setValue(uri)
+          .setExtract(isExtract(uri))
           .build()
       })
       builder.addAllUris(uriProtos.asJava)
@@ -199,6 +200,21 @@ object TaskBuilder {
     builder.build
   }
 
+  private def isExtract(stringuri: String): Boolean = {
+    if (stringuri.endsWith(".tgz") ||
+      stringuri.endsWith(".tar.gz") ||
+      stringuri.endsWith(".tbz2") ||
+      stringuri.endsWith(".tar.bz2") ||
+      stringuri.endsWith(".txz") ||
+      stringuri.endsWith(".tar.xz")) {
+      return true;
+    }
+    else {
+      return false;
+    }
+
+  }
+
   def environment(vars: Map[String, String]) = {
     val builder = Environment.newBuilder()
 

src/test/scala/mesosphere/mesos/TaskBuilderTest.scala

@@ -286,6 +286,29 @@ class TaskBuilderTest extends MarathonSpec {
     assert(Map.empty == env)
   }
 
+  test("TaskNoURIExtraction") {
+
+    val command =
+      TaskBuilder.commandInfo(AppDefinition(
+        id = "testApp".toPath,
+        cpus = 1,
+        mem = 64,
+        disk = 1,
+        executor = "//cmd",
+        uris = Seq("http://www.example.com", "http://www.example.com/test.tgz",
+          "example.tar.gz"),
+        ports = Seq(8080, 8081)
+      ), Seq(1000, 1001))
+
+    val uriinfo1 = command.getUris(0)
+    assert(uriinfo1.getExtract == false)
+    val uriinfo2 = command.getUris(1)
+    assert(uriinfo2.getExtract == true)
+    val uriinfo3 = command.getUris(2)
+    assert(uriinfo3.getExtract == true)
+
+  }
+
   def buildIfMatches(offer: Offer, app: AppDefinition) = {
     val taskTracker = mock[TaskTracker]