[
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:
[
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:
[
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
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
[
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
[
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
>
[
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
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
[
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