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/flume.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/flume.py')
| -rw-r--r-- | python/pyspark/streaming/flume.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/python/pyspark/streaming/flume.py b/python/pyspark/streaming/flume.py index c0cdc50d8d..b3d1905365 100644 --- a/python/pyspark/streaming/flume.py +++ b/python/pyspark/streaming/flume.py @@ -20,7 +20,7 @@ if sys.version >= "3": from io import BytesIO else: from StringIO import StringIO -from py4j.java_gateway import Py4JJavaError +from py4j.protocol import Py4JJavaError from pyspark.storagelevel import StorageLevel from pyspark.serializers import PairDeserializer, NoOpSerializer, UTF8Deserializer, read_int |