[
https://issues.apache.org/jira/browse/SPARK-4631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14296799#comment-14296799
]
Bilna P commented on SPARK-4631:
For me it works fine. Still I am trying to reproduce the
[
https://issues.apache.org/jira/browse/SPARK-4631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14296811#comment-14296811
]
Ye Xianjin commented on SPARK-4631:
---
[~dragos], Thread.sleep(50) do pass the test on my
[
https://issues.apache.org/jira/browse/SPARK-4631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14296812#comment-14296812
]
Ye Xianjin commented on SPARK-4631:
---
[~dragos], Thread.sleep(50) do pass the test on my
[
https://issues.apache.org/jira/browse/SPARK-4631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14296790#comment-14296790
]
Iulian Dragos commented on SPARK-4631:
--
[~advancedxy], I see the same exception in
[
https://issues.apache.org/jira/browse/SPARK-4631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14296840#comment-14296840
]
Iulian Dragos commented on SPARK-4631:
--
[~Bilna], do you also see the
[
https://issues.apache.org/jira/browse/SPARK-4631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14297081#comment-14297081
]
Iulian Dragos commented on SPARK-4631:
--
I opened [PR
[
https://issues.apache.org/jira/browse/SPARK-4631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14297080#comment-14297080
]
Apache Spark commented on SPARK-4631:
-
User 'dragos' has created a pull request for
[
https://issues.apache.org/jira/browse/SPARK-4631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14296232#comment-14296232
]
Ye Xianjin commented on SPARK-4631:
---
Hi [~dragos], I have the same issue here. I'd like
[
https://issues.apache.org/jira/browse/SPARK-4631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14295338#comment-14295338
]
Iulian Dragos commented on SPARK-4631:
--
I'll have a go at fixing it.
Add real unit
[
https://issues.apache.org/jira/browse/SPARK-4631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14295316#comment-14295316
]
Iulian Dragos commented on SPARK-4631:
--
This test exhibits a race condition.
[
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://issues.apache.org/jira/browse/SPARK-4631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14259549#comment-14259549
]
Devan commented on SPARK-4631:
--
Hi I like to work on adding mqtt unit test if no one already
[
https://issues.apache.org/jira/browse/SPARK-4631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14258546#comment-14258546
]
Tathagata Das commented on SPARK-4631:
--
[~prabeeshk] Any update on the original issue
[
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
[
https://issues.apache.org/jira/browse/SPARK-4631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14227433#comment-14227433
]
Jinesh commented on SPARK-4631:
---
MQTT is the one of the most popular queuing protcol in
[
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
[
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
[
https://issues.apache.org/jira/browse/SPARK-4631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14227076#comment-14227076
]
Tathagata Das commented on SPARK-4631:
--
[~prabeeshk] Could you please take a crack at
[
https://issues.apache.org/jira/browse/SPARK-4631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14227121#comment-14227121
]
Tathagata Das commented on SPARK-4631:
--
I am optimistically going ahead and upgrading
[
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
[
https://issues.apache.org/jira/browse/SPARK-4631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14227337#comment-14227337
]
Reynold Xin commented on SPARK-4631:
How popular is MQTT? Do we really need this
[
https://issues.apache.org/jira/browse/SPARK-4631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14227356#comment-14227356
]
Sean Owen commented on SPARK-4631:
--
(FWIW I had never heard of MQTT before Spark. This
22 matches
Mail list logo