diff --git a/README.md b/README.md
index 1eb1025..61bc68c 100644
--- a/README.md
+++ b/README.md
@@ -11,7 +11,7 @@ MongoRDD is on Bintray and Maven Central:
 	<dependency>
         <groupId>com.caffinc.sparktools</groupId>
         <artifactId>mongordd</artifactId>
-        <version>1.0.1</version>
+        <version>1.0.2</version>
     </dependency>
 
 MongoRDD extends the Spark RDD class and provides a way to read from MongoDB directly into Spark.
diff --git a/mongordd/pom.xml b/mongordd/pom.xml
index 0d34319..99677fa 100644
--- a/mongordd/pom.xml
+++ b/mongordd/pom.xml
@@ -6,7 +6,7 @@
 
     <groupId>com.caffinc.sparktools</groupId>
     <artifactId>mongordd</artifactId>
-    <version>1.0.1</version>
+    <version>1.0.2</version>
 
     <name>Mongo RDD</name>
     <description>MongoDB RDD for Spark</description>
diff --git a/mongordd/src/main/java/com/caffinc/sparktools/mongordd/MongoRDD.java b/mongordd/src/main/java/com/caffinc/sparktools/mongordd/MongoRDD.java
index d5354ce..c67b74a 100644
--- a/mongordd/src/main/java/com/caffinc/sparktools/mongordd/MongoRDD.java
+++ b/mongordd/src/main/java/com/caffinc/sparktools/mongordd/MongoRDD.java
@@ -121,7 +121,7 @@ public Document next() {
      *
      * @author Sriram
      */
-    private class MongoMapPartition implements Partition {
+    private static class MongoMapPartition implements Partition {
         private static final long serialVersionUID = 1L;
         private int index;
         private int from;
@@ -157,7 +157,7 @@ public int index() {
          */
         @Override
         public boolean equals(Object obj) {
-            return (obj instanceof MongoMapPartition) && ((MongoMapPartition) obj).index != index;
+            return (obj instanceof MongoMapPartition) && ((MongoMapPartition) obj).index == index;
         }
 
         /**