[
https://issues.apache.org/jira/browse/BAHIR-24?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15390756#comment-15390756
]
ASF subversion and git services commented on BAHIR-24:
------------------------------------------------------
Commit 12f130846ef7523138e98e79bfd823f61acab3b3 in bahir's branch
refs/heads/master from [~ckadner]
[ https://git-wip-us.apache.org/repos/asf?p=bahir.git;h=12f1308 ]
[BAHIR-24] fix MQTT Python code, examples, add tests
Changes in this PR:
- remove unnecessary files from streaming-mqtt/python
- updated all *.py files with respect to the modified
project structure pyspark.streaming.mqtt --> mqtt
- add test cases that were left out from the import and
add shell script to run them:
- streaming-mqtt/python-tests/run-python-tests.sh
- streaming-mqtt/python-tests/tests.py
- modify MQTTTestUtils.scala to limit the required disk storage space
- modify bin/run-example script to setup PYTHONPATH to run Python examples
Closes #10
> Fix MQTT Python code
> --------------------
>
> Key: BAHIR-24
> URL: https://issues.apache.org/jira/browse/BAHIR-24
> Project: Bahir
> Issue Type: Bug
> Components: Spark Streaming Connectors
> Affects Versions: 2.0.0
> Reporter: Christian Kadner
> Assignee: Christian Kadner
> Original Estimate: 12h
> Remaining Estimate: 12h
>
> When the Bahir project was created from Spark revision {{8301fadd8}} the
> Python code (incl. examples) were not updated with respect to the modified
> project structure and test cases were left out from the import.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)