fix CI error

apache · Jan 18, 2019 · 38978cc · 38978cc
1 parent 2c4bf51
commit 38978cc
Showing 1 changed file with 12 additions and 1 deletion.
diff --git a/...mmon-test/src/test/scala/org/apache/carbondata/alluxio/AlluxioWithExternalTableTest.scala b/...mmon-test/src/test/scala/org/apache/carbondata/alluxio/AlluxioWithExternalTableTest.scala
@@ -29,6 +29,7 @@ import org.apache.carbondata.core.constants.CarbonCommonConstants
 import org.apache.carbondata.core.util.CarbonProperties
 
 class AlluxioWithExternalTableTest extends AlluxioUtilTest with BeforeAndAfterAll {
+    var localFile = ""
     var remoteFile = ""
     var allDataTypeRemote = ""
     var allDataTypeLocal = ""
@@ -46,7 +47,7 @@ class AlluxioWithExternalTableTest extends AlluxioUtilTest with BeforeAndAfterAl
                 + "../../../..").getCanonicalPath
 
         val time = new SimpleDateFormat("yyyyMMddHHmmssSSS").format(new Date())
-        val localFile = rootPath + "/hadoop/src/test/resources/data.csv"
+        localFile = rootPath + "/hadoop/src/test/resources/data.csv"
         remoteFile = "/carbon_alluxio" + time + ".csv"
         fileSystemShell.run("copyFromLocal", localFile, remoteFile)
 
@@ -151,6 +152,11 @@ class AlluxioWithExternalTableTest extends AlluxioUtilTest with BeforeAndAfterAl
              """.stripMargin)
 
             val path = localAlluxioCluster.getMasterURI + remoteFile
+
+            val result = fileSystemShell.run("ls", path)
+            if (result < 0) {
+                fileSystemShell.run("copyFromLocal", localFile, remoteFile)
+            }
             sql(s"""LOAD DATA LOCAL INPATH '$path' INTO TABLE $tableNameOriginal""")
 
             fileSystemShell.run("ls", carbonAndAlluxio + "/default")
@@ -200,6 +206,11 @@ class AlluxioWithExternalTableTest extends AlluxioUtilTest with BeforeAndAfterAl
              """.stripMargin)
 
             val path = localAlluxioCluster.getMasterURI + remoteFile
+
+            val result = fileSystemShell.run("ls", path)
+            if (result < 0) {
+                fileSystemShell.run("copyFromLocal", localFile, remoteFile)
+            }
             sql(s"""LOAD DATA LOCAL INPATH '$path' INTO TABLE $tableNameOriginal""")
 
             fileSystemShell.run("ls", carbonAndAlluxio + "/default")