You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@carbondata.apache.org by ja...@apache.org on 2016/12/26 02:04:11 UTC
[1/2] incubator-carbondata git commit: fixed cluster issue
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 <ra...@gmail.com>
Authored: Sun Dec 25 21:00:08 2016 +0530
Committer: jackylk <ja...@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)
}
[2/2] incubator-carbondata git commit: [CARBONDATA-563] Fixed query
failing in cluster This closes #463
Posted by ja...@apache.org.
[CARBONDATA-563] Fixed query failing in cluster This closes #463
Project: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/commit/a0e66461
Tree: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/tree/a0e66461
Diff: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/diff/a0e66461
Branch: refs/heads/master
Commit: a0e66461ba6b27bfdf96fe9bf77667d2ffd26f9d
Parents: 4a8e15d bfb41c6
Author: jackylk <ja...@huawei.com>
Authored: Mon Dec 26 10:03:52 2016 +0800
Committer: jackylk <ja...@huawei.com>
Committed: Mon Dec 26 10:03:52 2016 +0800
----------------------------------------------------------------------
.../scala/org/apache/carbondata/spark/rdd/CarbonScanRDD.scala | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------