You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@bahir.apache.org by lr...@apache.org on 2016/06/10 15:23:47 UTC
[08/50] [abbrv] bahir git commit: [SPARK-10447][SPARK-3842][PYSPARK]
upgrade pyspark to py4j0.9
[SPARK-10447][SPARK-3842][PYSPARK] upgrade pyspark to py4j0.9
Upgrade to Py4j0.9
Author: Holden Karau <ho...@pigscanfly.ca>
Author: Holden Karau <ho...@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 <ho...@pigscanfly.ca>
Authored: Tue Oct 20 10:52:49 2015 -0700
Committer: Josh Rosen <jo...@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