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

2018-05-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BAHIR-164?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16471645#comment-16471645 ] ASF GitHub Bot commented on BAHIR-164: -- Github user ScrapCodes commented on the issue:

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

2018-05-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BAHIR-46?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16471639#comment-16471639 ] ASF GitHub Bot commented on BAHIR-46: - Github user ScrapCodes closed the pull request at:

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

2018-05-11 Thread Prashant Sharma (JIRA)
[ 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.

2018-05-11 Thread Prashant Sharma (JIRA)
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

2018-05-11 Thread Prashant Sharma (JIRA)
[ 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

2018-05-11 Thread Prashant Sharma (JIRA)
[ 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

2018-05-11 Thread Prashant Sharma (JIRA)
[ 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

2018-05-11 Thread Prashant Sharma (JIRA)
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.

2018-05-11 Thread Prashant Sharma (JIRA)
[ 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