carbondata-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chenliang...@apache.org
Subject [1/2] incubator-carbondata git commit: When splits is null, no need to return null CarbonSparkPartition
Date Tue, 30 Aug 2016 07:20:04 GMT
Repository: incubator-carbondata
Updated Branches:
  refs/heads/master 9bd37eae8 -> b5b0bad14


When splits is null, no need to return null CarbonSparkPartition


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

Branch: refs/heads/master
Commit: a561cebbfb7a2f493621c236d8237155a8ec15dc
Parents: 9bd37ea
Author: foryou2030 <foryou2030@126.com>
Authored: Sat Aug 27 18:05:38 2016 +0800
Committer: chenliang613 <chenliang613@apache.org>
Committed: Tue Aug 30 15:19:07 2016 +0800

----------------------------------------------------------------------
 .../scala/org/apache/carbondata/spark/rdd/CarbonScanRDD.scala    | 4 ----
 1 file changed, 4 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-carbondata/blob/a561cebb/integration/spark/src/main/scala/org/apache/carbondata/spark/rdd/CarbonScanRDD.scala
----------------------------------------------------------------------
diff --git a/integration/spark/src/main/scala/org/apache/carbondata/spark/rdd/CarbonScanRDD.scala
b/integration/spark/src/main/scala/org/apache/carbondata/spark/rdd/CarbonScanRDD.scala
index 6c0438f..65b55c7 100644
--- a/integration/spark/src/main/scala/org/apache/carbondata/spark/rdd/CarbonScanRDD.scala
+++ b/integration/spark/src/main/scala/org/apache/carbondata/spark/rdd/CarbonScanRDD.scala
@@ -157,14 +157,10 @@ class CarbonScanRDD[V: ClassTag](
         }
       } else {
         logInfo("No blocks identified to scan")
-        val nodesPerBlock = new util.ArrayList[TableBlockInfo]()
-        result.add(new CarbonSparkPartition(id, 0, Seq("").toArray, nodesPerBlock))
       }
     }
     else {
       logInfo("No valid segments found to scan")
-      val nodesPerBlock = new util.ArrayList[TableBlockInfo]()
-      result.add(new CarbonSparkPartition(id, 0, Seq("").toArray, nodesPerBlock))
     }
     result.toArray(new Array[Partition](result.size()))
   }


Mime
View raw message