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)
}
|