[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=16710958#comment-16710958 ] Prashant Sharma commented on BAHIR-184: --- They are not obsolete, people are still using 2.1.x or

[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

[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: -- Component/s: (was: Spark Streaming Connectors) Spark Structured Streaming

[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

[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

[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=16471528#comment-16471528 ] Prashant Sharma commented on BAHIR-165: --- My guess is mqtt connector currently tries to decode using

[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=16456281#comment-16456281 ] Prashant Sharma commented on BAHIR-164: --- MQTT source has to be migrated to new DataSourceV2 API. >

[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=15416952#comment-15416952 ] Prashant Sharma commented on BAHIR-51: -- QoS is set on message, when it is published. There is no way, I

[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] [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) >

[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

[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