Vij, This is because you're checking partitions for result DataFrame. IgniteRDD queries Ignite directly, gets the result back and wraps it into the DataFrame. If you do any transformations with this DataFrame, they are not parallelized and are done on the driver. Thus only one partition returned.
To get correct number of partitions for IgniteRDD, do like this: jic.fromCache(PARTITIONED_CACHE_NAME).getPartitions(); -Val -- View this message in context: http://apache-ignite-users.70518.x6.nabble.com/Number-of-partitions-of-IgniteRDD-tp4644p4708.html Sent from the Apache Ignite Users mailing list archive at Nabble.com.
