[jira] [Updated] (SPARK-6005) Flaky test: o.a.s.streaming.kafka.DirectKafkaStreamSuite.offset recovery

[ https://issues.apache.org/jira/browse/SPARK-6005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Iulian Dragos updated SPARK-6005: - Summary: Flaky test: o.a.s.streaming.kafka.DirectKafkaStreamSuite.offset recovery (was: Flaky

[jira] [Commented] (SPARK-4631) Add real unit test for MQTT

[ 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

[jira] [Commented] (SPARK-4631) Add real unit test for MQTT

[ 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

[jira] [Commented] (SPARK-4631) Add real unit test for MQTT

[ 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

[jira] [Commented] (SPARK-4631) Add real unit test for MQTT

[ 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

[jira] [Commented] (SPARK-4631) Add real unit test for MQTT

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

[jira] [Commented] (SPARK-2075) Anonymous classes are missing from Spark distribution

[ https://issues.apache.org/jira/browse/SPARK-2075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14178350#comment-14178350 ] Iulian Dragos commented on SPARK-2075: -- The name of the missing class is

[jira] [Commented] (SPARK-2075) Anonymous classes are missing from Spark distribution

[ https://issues.apache.org/jira/browse/SPARK-2075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14172394#comment-14172394 ] Iulian Dragos commented on SPARK-2075: -- The Scala compiler produces stable names for

<    1   2