diff --git a/python/pyspark/rdd.py b/python/pyspark/rdd.py index f64f48e3a4c9..7862a3dfe2be 100644 --- a/python/pyspark/rdd.py +++ b/python/pyspark/rdd.py @@ -181,7 +181,7 @@ def id(self): """ A unique ID for this RDD (within its SparkContext). """ - return self._id + return self._jrdd.id() def __repr__(self): return self._jrdd.toString()