[jira] (BEAM-1360) Reference to the obsolete python-sdk branch in the documentation.
Title: Message Title Prabeesh K created an issue Beam / BEAM-1360 Reference to the obsolete python-sdk branch in the documentation. Issue Type: Improvement Assignee: Davor Bonaci Components: project-management Created: 31/Jan/17 08:30 Priority: Major Reporter: Prabeesh K Following documents contains reference to obsolete python-sdk README PYTHON SDK README Add Comment
[jira] [Commented] (SPARK-9684) sbt/sbt assembly Error: Invalid or corrupt jarfile sbt/sbt-launch-0.13.6.jar
[ https://issues.apache.org/jira/browse/SPARK-9684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14659779#comment-14659779 ] Prabeesh K commented on SPARK-9684: --- [~pwendell] Please have a look sbt/sbt assembly Error: Invalid or corrupt jarfile sbt/sbt-launch-0.13.6.jar Key: SPARK-9684 URL: https://issues.apache.org/jira/browse/SPARK-9684 Project: Spark Issue Type: Bug Affects Versions: 1.1.0, 1.1.1 Reporter: Prabeesh K While running sbt/sbt assembly . Got following error. Attempting to fetch sbt Launching sbt from sbt/sbt-launch-0.13.6.jar Error: Invalid or corrupt jarfile sbt/sbt-launch-0.13.6.jar -- This message was sent by Atlassian JIRA (v6.3.4#6332) - To unsubscribe, e-mail: issues-unsubscr...@spark.apache.org For additional commands, e-mail: issues-h...@spark.apache.org
[jira] [Commented] (SPARK-9684) sbt/sbt assembly Error: Invalid or corrupt jarfile sbt/sbt-launch-0.13.6.jar
[ https://issues.apache.org/jira/browse/SPARK-9684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14659785#comment-14659785 ] Prabeesh K commented on SPARK-9684: --- It is fixed in the master. But I can't find a spark-1.X version with fix sbt/sbt assembly Error: Invalid or corrupt jarfile sbt/sbt-launch-0.13.6.jar Key: SPARK-9684 URL: https://issues.apache.org/jira/browse/SPARK-9684 Project: Spark Issue Type: Bug Affects Versions: 1.1.0, 1.1.1 Reporter: Prabeesh K While running sbt/sbt assembly . Got following error. Attempting to fetch sbt Launching sbt from sbt/sbt-launch-0.13.6.jar Error: Invalid or corrupt jarfile sbt/sbt-launch-0.13.6.jar -- This message was sent by Atlassian JIRA (v6.3.4#6332) - To unsubscribe, e-mail: issues-unsubscr...@spark.apache.org For additional commands, e-mail: issues-h...@spark.apache.org
[jira] [Created] (SPARK-9684) sbt/sbt assembly Error: Invalid or corrupt jarfile sbt/sbt-launch-0.13.6.jar
Prabeesh K created SPARK-9684: - Summary: sbt/sbt assembly Error: Invalid or corrupt jarfile sbt/sbt-launch-0.13.6.jar Key: SPARK-9684 URL: https://issues.apache.org/jira/browse/SPARK-9684 Project: Spark Issue Type: Bug Affects Versions: 1.1.1, 1.1.0 Reporter: Prabeesh K Attempting to fetch sbt Launching sbt from sbt/sbt-launch-0.13.6.jar Error: Invalid or corrupt jarfile sbt/sbt-launch-0.13.6.jar -- This message was sent by Atlassian JIRA (v6.3.4#6332) - To unsubscribe, e-mail: issues-unsubscr...@spark.apache.org For additional commands, e-mail: issues-h...@spark.apache.org
[jira] [Updated] (SPARK-9684) sbt/sbt assembly Error: Invalid or corrupt jarfile sbt/sbt-launch-0.13.6.jar
[ https://issues.apache.org/jira/browse/SPARK-9684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prabeesh K updated SPARK-9684: -- Description: While running sbt.sbt assembly . Got following error. Attempting to fetch sbt Launching sbt from sbt/sbt-launch-0.13.6.jar Error: Invalid or corrupt jarfile sbt/sbt-launch-0.13.6.jar was: Attempting to fetch sbt Launching sbt from sbt/sbt-launch-0.13.6.jar Error: Invalid or corrupt jarfile sbt/sbt-launch-0.13.6.jar sbt/sbt assembly Error: Invalid or corrupt jarfile sbt/sbt-launch-0.13.6.jar Key: SPARK-9684 URL: https://issues.apache.org/jira/browse/SPARK-9684 Project: Spark Issue Type: Bug Affects Versions: 1.1.0, 1.1.1 Reporter: Prabeesh K While running sbt.sbt assembly . Got following error. Attempting to fetch sbt Launching sbt from sbt/sbt-launch-0.13.6.jar Error: Invalid or corrupt jarfile sbt/sbt-launch-0.13.6.jar -- This message was sent by Atlassian JIRA (v6.3.4#6332) - To unsubscribe, e-mail: issues-unsubscr...@spark.apache.org For additional commands, e-mail: issues-h...@spark.apache.org
[jira] [Updated] (SPARK-9684) sbt/sbt assembly Error: Invalid or corrupt jarfile sbt/sbt-launch-0.13.6.jar
[ https://issues.apache.org/jira/browse/SPARK-9684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prabeesh K updated SPARK-9684: -- Description: While running sbt/sbt assembly . Got following error. Attempting to fetch sbt Launching sbt from sbt/sbt-launch-0.13.6.jar Error: Invalid or corrupt jarfile sbt/sbt-launch-0.13.6.jar was: While running sbt.sbt assembly . Got following error. Attempting to fetch sbt Launching sbt from sbt/sbt-launch-0.13.6.jar Error: Invalid or corrupt jarfile sbt/sbt-launch-0.13.6.jar sbt/sbt assembly Error: Invalid or corrupt jarfile sbt/sbt-launch-0.13.6.jar Key: SPARK-9684 URL: https://issues.apache.org/jira/browse/SPARK-9684 Project: Spark Issue Type: Bug Affects Versions: 1.1.0, 1.1.1 Reporter: Prabeesh K While running sbt/sbt assembly . Got following error. Attempting to fetch sbt Launching sbt from sbt/sbt-launch-0.13.6.jar Error: Invalid or corrupt jarfile sbt/sbt-launch-0.13.6.jar -- This message was sent by Atlassian JIRA (v6.3.4#6332) - To unsubscribe, e-mail: issues-unsubscr...@spark.apache.org For additional commands, e-mail: issues-h...@spark.apache.org
[jira] [Comment Edited] (SPARK-9684) sbt/sbt assembly Error: Invalid or corrupt jarfile sbt/sbt-launch-0.13.6.jar
[ https://issues.apache.org/jira/browse/SPARK-9684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14659785#comment-14659785 ] Prabeesh K edited comment on SPARK-9684 at 8/6/15 10:04 AM: It is fixed in the master. But I can't find a spark-1.X version with fix. When your going to release a spark-1.x fix ? was (Author: prabeeshk): It is fixed in the master. But I can't find a spark-1.X version with fix sbt/sbt assembly Error: Invalid or corrupt jarfile sbt/sbt-launch-0.13.6.jar Key: SPARK-9684 URL: https://issues.apache.org/jira/browse/SPARK-9684 Project: Spark Issue Type: Bug Affects Versions: 1.1.0, 1.1.1 Reporter: Prabeesh K While running sbt/sbt assembly . Got following error. Attempting to fetch sbt Launching sbt from sbt/sbt-launch-0.13.6.jar Error: Invalid or corrupt jarfile sbt/sbt-launch-0.13.6.jar -- This message was sent by Atlassian JIRA (v6.3.4#6332) - To unsubscribe, e-mail: issues-unsubscr...@spark.apache.org For additional commands, e-mail: issues-h...@spark.apache.org
[jira] [Created] (SPARK-9597) Spark Streaming + MQTT Integration Guide
Prabeesh K created SPARK-9597: - Summary: Spark Streaming + MQTT Integration Guide Key: SPARK-9597 URL: https://issues.apache.org/jira/browse/SPARK-9597 Project: Spark Issue Type: Documentation Components: Documentation Reporter: Prabeesh K -- This message was sent by Atlassian JIRA (v6.3.4#6332) - To unsubscribe, e-mail: issues-unsubscr...@spark.apache.org For additional commands, e-mail: issues-h...@spark.apache.org
[jira] [Updated] (SPARK-9597) Spark Streaming + MQTT Integration Guide
[ https://issues.apache.org/jira/browse/SPARK-9597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prabeesh K updated SPARK-9597: -- Description: Add Spark Streaming + Spark Streaming + MQTT Integration Guide Key: SPARK-9597 URL: https://issues.apache.org/jira/browse/SPARK-9597 Project: Spark Issue Type: Documentation Components: Documentation Reporter: Prabeesh K Add Spark Streaming + -- This message was sent by Atlassian JIRA (v6.3.4#6332) - To unsubscribe, e-mail: issues-unsubscr...@spark.apache.org For additional commands, e-mail: issues-h...@spark.apache.org
[jira] [Updated] (SPARK-9597) Spark Streaming + MQTT Integration Guide
[ https://issues.apache.org/jira/browse/SPARK-9597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prabeesh K updated SPARK-9597: -- Description: Add Spark Streaming + MQTT Integration Guide like [Spark Streaming + Flume Integration Guide|http://spark.apache.org/docs/latest/streaming-flume-integration.html] [Spark Streaming + Kinesis Integration|http://spark.apache.org/docs/latest/streaming-kinesis-integration.html] [Spark Streaming + Kafka Integration Guide|http://spark.apache.org/docs/latest/streaming-kafka-integration.html] was:Add Spark Streaming + Spark Streaming + MQTT Integration Guide Key: SPARK-9597 URL: https://issues.apache.org/jira/browse/SPARK-9597 Project: Spark Issue Type: Documentation Components: Documentation Reporter: Prabeesh K Add Spark Streaming + MQTT Integration Guide like [Spark Streaming + Flume Integration Guide|http://spark.apache.org/docs/latest/streaming-flume-integration.html] [Spark Streaming + Kinesis Integration|http://spark.apache.org/docs/latest/streaming-kinesis-integration.html] [Spark Streaming + Kafka Integration Guide|http://spark.apache.org/docs/latest/streaming-kafka-integration.html] -- This message was sent by Atlassian JIRA (v6.3.4#6332) - To unsubscribe, e-mail: issues-unsubscr...@spark.apache.org For additional commands, e-mail: issues-h...@spark.apache.org
[jira] [Updated] (SPARK-9597) Add Spark Streaming + MQTT Integration Guide
[ https://issues.apache.org/jira/browse/SPARK-9597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prabeesh K updated SPARK-9597: -- Summary: Add Spark Streaming + MQTT Integration Guide (was: Spark Streaming + MQTT Integration Guide) Add Spark Streaming + MQTT Integration Guide Key: SPARK-9597 URL: https://issues.apache.org/jira/browse/SPARK-9597 Project: Spark Issue Type: Documentation Components: Documentation Reporter: Prabeesh K Add Spark Streaming + MQTT Integration Guide like [Spark Streaming + Flume Integration Guide|http://spark.apache.org/docs/latest/streaming-flume-integration.html] [Spark Streaming + Kinesis Integration|http://spark.apache.org/docs/latest/streaming-kinesis-integration.html] [Spark Streaming + Kafka Integration Guide|http://spark.apache.org/docs/latest/streaming-kafka-integration.html] -- This message was sent by Atlassian JIRA (v6.3.4#6332) - To unsubscribe, e-mail: issues-unsubscr...@spark.apache.org For additional commands, e-mail: issues-h...@spark.apache.org
[jira] [Created] (SPARK-5666) Adhere to accepte coding standards
Prabeesh K created SPARK-5666: - Summary: Adhere to accepte coding standards Key: SPARK-5666 URL: https://issues.apache.org/jira/browse/SPARK-5666 Project: Spark Issue Type: Improvement Components: Streaming Reporter: Prabeesh K Priority: Minor Cleanup the the all source code related to the Mqtt Spark Streaming to adhere to accept coding standards. -- This message was sent by Atlassian JIRA (v6.3.4#6332) - To unsubscribe, e-mail: issues-unsubscr...@spark.apache.org For additional commands, e-mail: issues-h...@spark.apache.org
[jira] [Updated] (SPARK-5666) Adhere to accepte coding standards
[ https://issues.apache.org/jira/browse/SPARK-5666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prabeesh K updated SPARK-5666: -- Description: Cleanup the source code related to the Mqtt Spark Streaming to adhere to accept coding standards. (was: Cleanup the the all source code related to the Mqtt Spark Streaming to adhere to accept coding standards.) Adhere to accepte coding standards -- Key: SPARK-5666 URL: https://issues.apache.org/jira/browse/SPARK-5666 Project: Spark Issue Type: Improvement Components: Streaming Reporter: Prabeesh K Priority: Minor Cleanup the source code related to the Mqtt Spark Streaming to adhere to accept coding standards. -- This message was sent by Atlassian JIRA (v6.3.4#6332) - To unsubscribe, e-mail: issues-unsubscr...@spark.apache.org For additional commands, e-mail: issues-h...@spark.apache.org
[jira] [Commented] (SPARK-5666) Adhere to accepte coding standards
[ https://issues.apache.org/jira/browse/SPARK-5666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14310845#comment-14310845 ] Prabeesh K commented on SPARK-5666: --- [~srowen] Please review this Adhere to accepte coding standards -- Key: SPARK-5666 URL: https://issues.apache.org/jira/browse/SPARK-5666 Project: Spark Issue Type: Improvement Components: Streaming Reporter: Prabeesh K Priority: Minor Cleanup the source code related to the Mqtt Spark Streaming to adhere to accept coding standards. -- This message was sent by Atlassian JIRA (v6.3.4#6332) - To unsubscribe, e-mail: issues-unsubscr...@spark.apache.org For additional commands, e-mail: issues-h...@spark.apache.org
[jira] [Updated] (SPARK-5666) Adhere to accept coding standards
[ https://issues.apache.org/jira/browse/SPARK-5666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prabeesh K updated SPARK-5666: -- Summary: Adhere to accept coding standards (was: Adhere to accepte coding standards) Adhere to accept coding standards - Key: SPARK-5666 URL: https://issues.apache.org/jira/browse/SPARK-5666 Project: Spark Issue Type: Improvement Components: Streaming Reporter: Prabeesh K Priority: Minor Cleanup the source code related to the Mqtt Spark Streaming to adhere to accept coding standards. -- This message was sent by Atlassian JIRA (v6.3.4#6332) - To unsubscribe, e-mail: issues-unsubscr...@spark.apache.org For additional commands, e-mail: issues-h...@spark.apache.org
[jira] [Updated] (SPARK-5666) To accept coding standards
[ https://issues.apache.org/jira/browse/SPARK-5666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prabeesh K updated SPARK-5666: -- Summary: To accept coding standards (was: Adhere to accept coding standards) To accept coding standards -- Key: SPARK-5666 URL: https://issues.apache.org/jira/browse/SPARK-5666 Project: Spark Issue Type: Improvement Components: Streaming Reporter: Prabeesh K Priority: Minor Cleanup the source code related to the Mqtt Spark Streaming to adhere to accept coding standards. -- This message was sent by Atlassian JIRA (v6.3.4#6332) - To unsubscribe, e-mail: issues-unsubscr...@spark.apache.org For additional commands, e-mail: issues-h...@spark.apache.org
[jira] [Commented] (SPARK-5666) To accept coding standards
[ https://issues.apache.org/jira/browse/SPARK-5666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14310851#comment-14310851 ] Prabeesh K commented on SPARK-5666: --- Primary concern is to improve the code related to the MQTT. Please update the title and PR title accordingly. To accept coding standards -- Key: SPARK-5666 URL: https://issues.apache.org/jira/browse/SPARK-5666 Project: Spark Issue Type: Improvement Components: Streaming Reporter: Prabeesh K Priority: Minor Cleanup the source code related to the Mqtt Spark Streaming to adhere to accept coding standards. -- This message was sent by Atlassian JIRA (v6.3.4#6332) - To unsubscribe, e-mail: issues-unsubscr...@spark.apache.org For additional commands, e-mail: issues-h...@spark.apache.org
[jira] [Updated] (SPARK-5666) Improvements in Mqtt Spark Streaming
[ https://issues.apache.org/jira/browse/SPARK-5666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prabeesh K updated SPARK-5666: -- Summary: Improvements in Mqtt Spark Streaming (was: To accept coding standards) Improvements in Mqtt Spark Streaming - Key: SPARK-5666 URL: https://issues.apache.org/jira/browse/SPARK-5666 Project: Spark Issue Type: Improvement Components: Streaming Reporter: Prabeesh K Priority: Minor Cleanup the source code related to the Mqtt Spark Streaming to adhere to accept coding standards. -- This message was sent by Atlassian JIRA (v6.3.4#6332) - To unsubscribe, e-mail: issues-unsubscr...@spark.apache.org For additional commands, e-mail: issues-h...@spark.apache.org
[jira] [Commented] (SPARK-4631) Add real unit test for MQTT
[ https://issues.apache.org/jira/browse/SPARK-4631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14261080#comment-14261080 ] Prabeesh K commented on SPARK-4631: --- [~tdas] please refer https://github.com/apache/spark/pull/3844 Add real unit test for MQTT Key: SPARK-4631 URL: https://issues.apache.org/jira/browse/SPARK-4631 Project: Spark Issue Type: Test Components: Streaming Reporter: Tathagata Das Priority: Critical A real unit test that actually transfers data to ensure that the MQTTUtil is functional -- This message was sent by Atlassian JIRA (v6.3.4#6332) - To unsubscribe, e-mail: issues-unsubscr...@spark.apache.org For additional commands, e-mail: issues-h...@spark.apache.org
[jira] [Comment Edited] (SPARK-4631) Add real unit test for MQTT
[ https://issues.apache.org/jira/browse/SPARK-4631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14227402#comment-14227402 ] Prabeesh K edited comment on SPARK-4631 at 11/27/14 8:49 AM: - MQTT is known as protocol of IoT(Internet of Things). It is widely used in IoT area. was (Author: prabeeshk): MQTT is know as protocol of IoT(Internet of Things). It is widely used in IoT area. Add real unit test for MQTT Key: SPARK-4631 URL: https://issues.apache.org/jira/browse/SPARK-4631 Project: Spark Issue Type: Test Components: Streaming Reporter: Tathagata Das Priority: Critical A real unit test that actually transfers data to ensure that the MQTTUtil is functional -- This message was sent by Atlassian JIRA (v6.3.4#6332) - To unsubscribe, e-mail: issues-unsubscr...@spark.apache.org For additional commands, e-mail: issues-h...@spark.apache.org
[jira] [Commented] (SPARK-4631) Add real unit test for MQTT
[ https://issues.apache.org/jira/browse/SPARK-4631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14227402#comment-14227402 ] Prabeesh K commented on SPARK-4631: --- MQTT is know as protocol of IoT(Internet of Things). It is widely used in IoT area. Add real unit test for MQTT Key: SPARK-4631 URL: https://issues.apache.org/jira/browse/SPARK-4631 Project: Spark Issue Type: Test Components: Streaming Reporter: Tathagata Das Priority: Critical A real unit test that actually transfers data to ensure that the MQTTUtil is functional -- This message was sent by Atlassian JIRA (v6.3.4#6332) - To unsubscribe, e-mail: issues-unsubscr...@spark.apache.org For additional commands, e-mail: issues-h...@spark.apache.org
[jira] [Commented] (SPARK-4631) Add real unit test for MQTT
[ https://issues.apache.org/jira/browse/SPARK-4631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14227472#comment-14227472 ] Prabeesh K commented on SPARK-4631: --- They fixed the issue now we have data in the [repo|https://repo.eclipse.org/content/repositories/paho-releases/org/eclipse/paho/mqtt-client/0.4.0/] Add real unit test for MQTT Key: SPARK-4631 URL: https://issues.apache.org/jira/browse/SPARK-4631 Project: Spark Issue Type: Test Components: Streaming Reporter: Tathagata Das Priority: Critical A real unit test that actually transfers data to ensure that the MQTTUtil is functional -- This message was sent by Atlassian JIRA (v6.3.4#6332) - To unsubscribe, e-mail: issues-unsubscr...@spark.apache.org For additional commands, e-mail: issues-h...@spark.apache.org
[jira] [Commented] (SPARK-4632) Upgrade MQTT dependency to use latest mqtt-client
[ https://issues.apache.org/jira/browse/SPARK-4632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14227473#comment-14227473 ] Prabeesh K commented on SPARK-4632: --- They fixed the issue now we have data in the [repo|https://repo.eclipse.org/content/repositories/paho-releases/org/eclipse/paho/mqtt-client/0.4.0/]. Now the older one works perfectly Upgrade MQTT dependency to use latest mqtt-client - Key: SPARK-4632 URL: https://issues.apache.org/jira/browse/SPARK-4632 Project: Spark Issue Type: Improvement Components: Streaming Affects Versions: 1.0.2, 1.1.1 Reporter: Tathagata Das Assignee: Tathagata Das Priority: Blocker mqtt client 0.4.0 was removed from the Eclipse Paho repository, and hence is breaking Spark build. -- This message was sent by Atlassian JIRA (v6.3.4#6332) - To unsubscribe, e-mail: issues-unsubscr...@spark.apache.org For additional commands, e-mail: issues-h...@spark.apache.org
[jira] [Commented] (SPARK-4631) Add real unit test for MQTT
[ https://issues.apache.org/jira/browse/SPARK-4631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14227506#comment-14227506 ] Prabeesh K commented on SPARK-4631: --- [~tdas] refer [this links|http://dev.eclipse.org/mhonarc/lists/paho-dev/msg02291.html] for the discusion going on the paho dev form. Add real unit test for MQTT Key: SPARK-4631 URL: https://issues.apache.org/jira/browse/SPARK-4631 Project: Spark Issue Type: Test Components: Streaming Reporter: Tathagata Das Priority: Critical A real unit test that actually transfers data to ensure that the MQTTUtil is functional -- This message was sent by Atlassian JIRA (v6.3.4#6332) - To unsubscribe, e-mail: issues-unsubscr...@spark.apache.org For additional commands, e-mail: issues-h...@spark.apache.org
[jira] [Commented] (SPARK-4631) Add real unit test for MQTT
[ https://issues.apache.org/jira/browse/SPARK-4631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14227309#comment-14227309 ] Prabeesh K commented on SPARK-4631: --- [~tdas] Please update to new [resolver|https://repo.eclipse.org/content/repositories/paho/] from the [older resolver | https://repo.eclipse.org/content/repositories/paho-releases/] Also update the external/mqtt/pom.xml with following groupIdorg.eclipse.paho/groupId artifactIdmqtt-client/artifactId version0.4.1-SNAPSHOT/version Add real unit test for MQTT Key: SPARK-4631 URL: https://issues.apache.org/jira/browse/SPARK-4631 Project: Spark Issue Type: Test Components: Streaming Reporter: Tathagata Das Priority: Critical A real unit test that actually transfers data to ensure that the MQTTUtil is functional -- This message was sent by Atlassian JIRA (v6.3.4#6332) - To unsubscribe, e-mail: issues-unsubscr...@spark.apache.org For additional commands, e-mail: issues-h...@spark.apache.org
[jira] [Comment Edited] (SPARK-4631) Add real unit test for MQTT
[ https://issues.apache.org/jira/browse/SPARK-4631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14227309#comment-14227309 ] Prabeesh K edited comment on SPARK-4631 at 11/27/14 6:54 AM: - [~tdas] Please update to new [resolver|https://repo.eclipse.org/content/repositories/paho/] from the [older resolver | https://repo.eclipse.org/content/repositories/paho-releases/] Also update the external/mqtt/pom.xml with following groupIdorg.eclipse.paho/groupId artifactIdmqtt-client/artifactId version0.4.1-SNAPSHOT/version Refre SPARK-4632 was (Author: prabeeshk): [~tdas] Please update to new [resolver|https://repo.eclipse.org/content/repositories/paho/] from the [older resolver | https://repo.eclipse.org/content/repositories/paho-releases/] Also update the external/mqtt/pom.xml with following groupIdorg.eclipse.paho/groupId artifactIdmqtt-client/artifactId version0.4.1-SNAPSHOT/version Add real unit test for MQTT Key: SPARK-4631 URL: https://issues.apache.org/jira/browse/SPARK-4631 Project: Spark Issue Type: Test Components: Streaming Reporter: Tathagata Das Priority: Critical A real unit test that actually transfers data to ensure that the MQTTUtil is functional -- This message was sent by Atlassian JIRA (v6.3.4#6332) - To unsubscribe, e-mail: issues-unsubscr...@spark.apache.org For additional commands, e-mail: issues-h...@spark.apache.org
[jira] [Commented] (SPARK-2377) Create a Python API for Spark Streaming
[ https://issues.apache.org/jira/browse/SPARK-2377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14182580#comment-14182580 ] Prabeesh K commented on SPARK-2377: --- Hi [~tdas], I wish start on Python API MQTT Streaming. Which branch I can use for adding this ? cc: [~davies], [~giwa] Create a Python API for Spark Streaming --- Key: SPARK-2377 URL: https://issues.apache.org/jira/browse/SPARK-2377 Project: Spark Issue Type: New Feature Components: PySpark, Streaming Reporter: Nicholas Chammas Assignee: Kenichi Takagiwa Fix For: 1.2.0 [Spark Streaming|http://spark.apache.org/docs/latest/streaming-programming-guide.html] currently offers APIs in Scala and Java. It would be great feature add to have a Python API as well. This is probably a large task that will span many issues if undertaken. This ticket should provide some place to track overall progress towards an initial Python API for Spark Streaming. -- This message was sent by Atlassian JIRA (v6.3.4#6332) - To unsubscribe, e-mail: issues-unsubscr...@spark.apache.org For additional commands, e-mail: issues-h...@spark.apache.org
[jira] [Commented] (STORM-310) Change Twitter authentication stream using the new Twitter4J. An optional set of filters can be used to restricted tweets.
[ https://issues.apache.org/jira/browse/STORM-310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13997795#comment-13997795 ] Prabeesh K commented on STORM-310: -- Thank you Change Twitter authentication stream using the new Twitter4J. An optional set of filters can be used to restricted tweets. -- Key: STORM-310 URL: https://issues.apache.org/jira/browse/STORM-310 Project: Apache Storm (Incubating) Issue Type: Improvement Reporter: Prabeesh K Fix For: 0.9.2-incubating Due to Twitter API update , unable stream the data from twitter using basic auth. https://dev.twitter.com/blog/api-v1-is-retired Retirement of deprecated API v1.0. Retirement of Basic Auth support on Streaming API. https://dev.twitter.com/calendar. So changed Twitter authentication stream using the new Twitter4J. -- This message was sent by Atlassian JIRA (v6.2#6252)
