[SPARK-10447][SPARK-3842][PYSPARK] upgrade pyspark to py4j0.9 Upgrade to Py4j0.9
Author: Holden Karau <hol...@pigscanfly.ca> Author: Holden Karau <hol...@us.ibm.com> Closes #8615 from holdenk/SPARK-10447-upgrade-pyspark-to-py4j0.9. Project: http://git-wip-us.apache.org/repos/asf/bahir/repo Commit: http://git-wip-us.apache.org/repos/asf/bahir/commit/c03f462b Tree: http://git-wip-us.apache.org/repos/asf/bahir/tree/c03f462b Diff: http://git-wip-us.apache.org/repos/asf/bahir/diff/c03f462b Branch: refs/heads/master Commit: c03f462ba694e34dd191d2edba8881484e5e76b3 Parents: 5618911 Author: Holden Karau <hol...@pigscanfly.ca> Authored: Tue Oct 20 10:52:49 2015 -0700 Committer: Josh Rosen <joshro...@databricks.com> Committed: Tue Oct 20 10:52:49 2015 -0700 ---------------------------------------------------------------------- streaming-mqtt/python/mqtt.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/bahir/blob/c03f462b/streaming-mqtt/python/mqtt.py ---------------------------------------------------------------------- diff --git a/streaming-mqtt/python/mqtt.py b/streaming-mqtt/python/mqtt.py index fa83006..1ce4093 100644 --- a/streaming-mqtt/python/mqtt.py +++ b/streaming-mqtt/python/mqtt.py @@ -15,7 +15,7 @@ # limitations under the License. # -from py4j.java_gateway import Py4JJavaError +from py4j.protocol import Py4JJavaError from pyspark.storagelevel import StorageLevel from pyspark.serializers import UTF8Deserializer