[SPARK] Remove RDD check to avoid double evaluation

relates #631
elastic · Jan 8, 2016 · fc96529 · fc96529
1 parent a677e61
commit fc96529
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/spark/core/main/scala/org/elasticsearch/spark/rdd/EsSpark.scala b/spark/core/main/scala/org/elasticsearch/spark/rdd/EsSpark.scala
@@ -56,7 +56,7 @@ object EsSpark {
   def saveToEs(rdd: RDD[_], cfg: Map[String, String]) {
     CompatUtils.warnSchemaRDD(rdd, LogFactory.getLog("org.elasticsearch.spark.rdd.EsSpark"))
 
-    if (rdd == null || rdd.partitions.length == 0 || rdd.take(1).length == 0) {
+    if (rdd == null || rdd.partitions.length == 0) {
       return
     }