diff options
author | Holden Karau <holden@pigscanfly.ca> | 2015-10-20 10:52:49 -0700 |
---|---|---|
committer | Josh Rosen <joshrosen@databricks.com> | 2015-10-20 10:52:49 -0700 |
commit | e18b571c3374ecbfc0b20a5064cb58d57a2a7d21 (patch) | |
tree | e80aeebc7f8a247dff692f46a2bf7860a0e592dc /python/pyspark/streaming/kafka.py | |
parent | 94139557c56cea318d4a4f82a4deaf72198f349a (diff) | |
download | spark-e18b571c3374ecbfc0b20a5064cb58d57a2a7d21.tar.gz spark-e18b571c3374ecbfc0b20a5064cb58d57a2a7d21.tar.bz2 spark-e18b571c3374ecbfc0b20a5064cb58d57a2a7d21.zip |
[SPARK-10447][SPARK-3842][PYSPARK] upgrade pyspark to py4j0.9
Upgrade to Py4j0.9
Author: Holden Karau <holden@pigscanfly.ca>
Author: Holden Karau <holden@us.ibm.com>
Closes #8615 from holdenk/SPARK-10447-upgrade-pyspark-to-py4j0.9.
Diffstat (limited to 'python/pyspark/streaming/kafka.py')
-rw-r--r-- | python/pyspark/streaming/kafka.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/python/pyspark/streaming/kafka.py b/python/pyspark/streaming/kafka.py index 8a814c64c0..b35bbaf404 100644 --- a/python/pyspark/streaming/kafka.py +++ b/python/pyspark/streaming/kafka.py @@ -15,7 +15,7 @@ # limitations under the License. # -from py4j.java_gateway import Py4JJavaError +from py4j.protocol import Py4JJavaError from pyspark.rdd import RDD from pyspark.storagelevel import StorageLevel |