carbondata-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jack...@apache.org
Subject [1/2] incubator-carbondata git commit: fixed cluster issue
Date Mon, 26 Dec 2016 02:04:11 GMT
Repository: incubator-carbondata
Updated Branches:
  refs/heads/master 4a8e15d34 -> a0e66461b


fixed cluster issue


Project: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/commit/bfb41c6c
Tree: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/tree/bfb41c6c
Diff: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/diff/bfb41c6c

Branch: refs/heads/master
Commit: bfb41c6cdc52b37baa718b49f7637156a1d2562f
Parents: 4a8e15d
Author: ravipesala <ravi.pesala@gmail.com>
Authored: Sun Dec 25 21:00:08 2016 +0530
Committer: jackylk <jacky.likun@huawei.com>
Committed: Mon Dec 26 10:03:29 2016 +0800

----------------------------------------------------------------------
 .../scala/org/apache/carbondata/spark/rdd/CarbonScanRDD.scala    | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-carbondata/blob/bfb41c6c/integration/spark-common/src/main/scala/org/apache/carbondata/spark/rdd/CarbonScanRDD.scala
----------------------------------------------------------------------
diff --git a/integration/spark-common/src/main/scala/org/apache/carbondata/spark/rdd/CarbonScanRDD.scala
b/integration/spark-common/src/main/scala/org/apache/carbondata/spark/rdd/CarbonScanRDD.scala
index f20d12d..2705f94 100644
--- a/integration/spark-common/src/main/scala/org/apache/carbondata/spark/rdd/CarbonScanRDD.scala
+++ b/integration/spark-common/src/main/scala/org/apache/carbondata/spark/rdd/CarbonScanRDD.scala
@@ -63,6 +63,8 @@ class CarbonScanRDD(
   }
   private var vectorReader = false
 
+  private val readSupport = SparkReadSupport.readSupportClass
+
   @transient private val jobId = new JobID(jobTrackerId, id)
   @transient val LOGGER = LogServiceFactory.getLogService(this.getClass.getName)
 
@@ -214,7 +216,7 @@ class CarbonScanRDD(
   }
 
   private def prepareInputFormatForExecutor(conf: Configuration): CarbonInputFormat[Object]
= {
-    CarbonInputFormat.setCarbonReadSupport(conf, SparkReadSupport.readSupportClass)
+    CarbonInputFormat.setCarbonReadSupport(conf, readSupport)
     createInputFormat(conf)
   }
 


Mime
View raw message