[jira] [Commented] (BAHIR-184) Please delete old releases from mirroring system

[ https://issues.apache.org/jira/browse/BAHIR-184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16710958#comment-16710958 ] Prashant Sharma commented on BAHIR-184: --- They are not obsolete, people are still usi

[jira] [Resolved] (BAHIR-46) Handle re-delivery of message in MQTT structured streaming source.

[ https://issues.apache.org/jira/browse/BAHIR-46?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prashant Sharma resolved BAHIR-46. -- Resolution: Won't Fix Fix Version/s: Spark-2.3 Mqtt does not give an easy way to determine

[jira] [Updated] (BAHIR-166) Migrate akka sql streaming source to datasrouce v2 API

[ https://issues.apache.org/jira/browse/BAHIR-166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prashant Sharma updated BAHIR-166: -- Issue Type: Sub-task (was: Bug) Parent: BAHIR-167 > Migrate akka sql streaming source to

[jira] [Created] (BAHIR-167) Update Bahir to use the new Spark 2.3.0 and datasource v2 API.

Prashant Sharma created BAHIR-167: - Summary: Update Bahir to use the new Spark 2.3.0 and datasource v2 API. Key: BAHIR-167 URL: https://issues.apache.org/jira/browse/BAHIR-167 Project: Bahir

[jira] [Updated] (BAHIR-164) Spark Streaming with MQTT fails with Spark 2.3.0

[ https://issues.apache.org/jira/browse/BAHIR-164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prashant Sharma updated BAHIR-164: -- Issue Type: Sub-task (was: Bug) Parent: BAHIR-167 > Spark Streaming with MQTT fails with

[jira] [Updated] (BAHIR-164) Spark Streaming with MQTT fails with Spark 2.3.0

[ https://issues.apache.org/jira/browse/BAHIR-164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prashant Sharma updated BAHIR-164: -- Component/s: (was: Spark Streaming Connectors) Spark Structured Streaming Con

[jira] [Updated] (BAHIR-166) Migrate akka sql streaming source to datasrouce v2 API

[ https://issues.apache.org/jira/browse/BAHIR-166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prashant Sharma updated BAHIR-166: -- Affects Version/s: Spark-2.3 > Migrate akka sql streaming source to datasrouce v2 API > -

[jira] [Updated] (BAHIR-166) Migrate akka sql streaming source to datasrouce v2 API

[ https://issues.apache.org/jira/browse/BAHIR-166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prashant Sharma updated BAHIR-166: -- Component/s: Spark Structured Streaming Connectors > Migrate akka sql streaming source to datasro

[jira] [Created] (BAHIR-166) Migrate akka sql streaming source to datasrouce v2 API

Prashant Sharma created BAHIR-166: - Summary: Migrate akka sql streaming source to datasrouce v2 API Key: BAHIR-166 URL: https://issues.apache.org/jira/browse/BAHIR-166 Project: Bahir Issue Ty

[jira] [Commented] (BAHIR-165) The avro messages to streaming-mqtt gives negative value.

[ https://issues.apache.org/jira/browse/BAHIR-165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16471528#comment-16471528 ] Prashant Sharma commented on BAHIR-165: --- My guess is mqtt connector currently tries t

[jira] [Commented] (BAHIR-164) Spark Streaming with MQTT fails with Spark 2.3.0

[ https://issues.apache.org/jira/browse/BAHIR-164?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16456281#comment-16456281 ] Prashant Sharma commented on BAHIR-164: --- MQTT source has to be migrated to new DataSo

[jira] [Commented] (BAHIR-83) Flaky test in BasicMQTTSourceSuite

[ https://issues.apache.org/jira/browse/BAHIR-83?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15728520#comment-15728520 ] Prashant Sharma commented on BAHIR-83: -- Taking a quick look it is not obvious what coul

[jira] [Commented] (BAHIR-51) Add additional MQTT options/parameters to MQTTInputDStream and MqttStreamSource

[ https://issues.apache.org/jira/browse/BAHIR-51?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15416981#comment-15416981 ] Prashant Sharma commented on BAHIR-51: -- I was preparing a PR for MqttStreamSource with

[jira] [Commented] (BAHIR-51) Add additional MQTT options/parameters to MQTTInputDStream and MqttStreamSource

[ https://issues.apache.org/jira/browse/BAHIR-51?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15416979#comment-15416979 ] Prashant Sharma commented on BAHIR-51: -- Thank you !, It was my oversight. > Add additi

[jira] [Commented] (BAHIR-51) Add additional MQTT options/parameters to MQTTInputDStream and MqttStreamSource

[ https://issues.apache.org/jira/browse/BAHIR-51?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15416952#comment-15416952 ] Prashant Sharma commented on BAHIR-51: -- QoS is set on message, when it is published. Th

[jira] [Created] (BAHIR-49) Add MQTTSink to SQL Streaming MQTT.

Prashant Sharma created BAHIR-49: Summary: Add MQTTSink to SQL Streaming MQTT. Key: BAHIR-49 URL: https://issues.apache.org/jira/browse/BAHIR-49 Project: Bahir Issue Type: New Feature

[jira] [Resolved] (BAHIR-48) Documentation improvements for Bahir README.md

[ https://issues.apache.org/jira/browse/BAHIR-48?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prashant Sharma resolved BAHIR-48. -- Resolution: Fixed Assignee: Prashant Sharma Fix Version/s: 2.0.0 > Documentation i

[jira] [Updated] (BAHIR-48) Documentation improvements for Bahir README.md

[ https://issues.apache.org/jira/browse/BAHIR-48?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prashant Sharma updated BAHIR-48: - Summary: Documentation improvements for Bahir README.md (was: Documentation improvements) > Docume

[jira] [Created] (BAHIR-48) Documentation improvements

Prashant Sharma created BAHIR-48: Summary: Documentation improvements Key: BAHIR-48 URL: https://issues.apache.org/jira/browse/BAHIR-48 Project: Bahir Issue Type: Improvement Repo

[jira] [Created] (BAHIR-46) Handle re-delivery of message in MQTT structured streaming source.

Prashant Sharma created BAHIR-46: Summary: Handle re-delivery of message in MQTT structured streaming source. Key: BAHIR-46 URL: https://issues.apache.org/jira/browse/BAHIR-46 Project: Bahir

[jira] [Updated] (BAHIR-45) Add cleanup support to SQL-STREAMING-MQTT Source once SPARK-16963 is fixed.

[ https://issues.apache.org/jira/browse/BAHIR-45?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prashant Sharma updated BAHIR-45: - Description: Currently, source tries to persist all the incoming messages to allow for minimal level

[jira] [Updated] (BAHIR-45) Add cleanup support to SQL-STREAMING-MQTT Source once SPARK-16963 is fixed.

[ https://issues.apache.org/jira/browse/BAHIR-45?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prashant Sharma updated BAHIR-45: - Summary: Add cleanup support to SQL-STREAMING-MQTT Source once SPARK-16963 is fixed. (was: Add clea

[jira] [Created] (BAHIR-45) Add cleanup support SQL-STREAMING-MQTT Source once SPARK-16963 is fixed.

Prashant Sharma created BAHIR-45: Summary: Add cleanup support SQL-STREAMING-MQTT Source once SPARK-16963 is fixed. Key: BAHIR-45 URL: https://issues.apache.org/jira/browse/BAHIR-45 Project: Bahir

[jira] [Created] (BAHIR-39) MQTT as a streaming source for SQL Streaming.

Prashant Sharma created BAHIR-39: Summary: MQTT as a streaming source for SQL Streaming. Key: BAHIR-39 URL: https://issues.apache.org/jira/browse/BAHIR-39 Project: Bahir Issue Type: New Featu