fix the CI error

apache · Jan 15, 2019 · 0914b75 · 0914b75
1 parent 91b2872
commit 0914b75
Showing 1 changed file with 3 additions and 4 deletions.
diff --git a/...cala/org/apache/carbondata/integration/spark/testsuite/dataload/TestLoadDataGeneral.scala b/...cala/org/apache/carbondata/integration/spark/testsuite/dataload/TestLoadDataGeneral.scala
@@ -22,13 +22,12 @@ import java.math.BigDecimal
 import scala.collection.mutable.ArrayBuffer
 
 import org.apache.spark.sql.Row
+import org.apache.spark.sql.test.util.QueryTest
 import org.scalatest.BeforeAndAfterEach
 
 import org.apache.carbondata.core.util.path.CarbonTablePath
 import org.apache.carbondata.core.datastore.impl.FileFactory
 import org.apache.carbondata.core.metadata.CarbonMetadata
-import org.apache.spark.sql.test.util.QueryTest
-
 import org.apache.carbondata.core.constants.{CarbonCommonConstants, CarbonLoadOptionConstants}
 import org.apache.carbondata.core.datamap.Segment
 import org.apache.carbondata.core.util.CarbonProperties
@@ -192,7 +191,7 @@ class TestLoadDataGeneral extends QueryTest with BeforeAndAfterEach {
       sql(s"load data local inpath '$testdata' into table load32000bytes OPTIONS ('FILEHEADER'='name')")
     }.getMessage.contains("DataLoad failure: Dataload failed, String size cannot exceed 32000 bytes"))
 
-    val source = scala.io.Source.fromFile(testdata)
+    val source = scala.io.Source.fromFile(testdata, CarbonCommonConstants.DEFAULT_CHARSET)
     val data = source.mkString
 
     intercept[Exception] {
@@ -216,7 +215,7 @@ class TestLoadDataGeneral extends QueryTest with BeforeAndAfterEach {
       sql(s"load data local inpath '$testdata' into table load32000bytes OPTIONS ('FILEHEADER'='name')")
     }.getMessage.contains("generate global dictionary failed, Dataload failed, String size cannot exceed 32000 bytes"))
 
-    val source = scala.io.Source.fromFile(testdata)
+    val source = scala.io.Source.fromFile(testdata, CarbonCommonConstants.DEFAULT_CHARSET)
     val data = source.mkString
 
     intercept[Exception] {