[jira] [Commented] (SPARK-18193) queueStream not updated if rddQueue.add after create queueStream in Java

2016-11-04 Thread Hubert Kang (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-18193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15636531#comment-15636531 ] Hubert Kang commented on SPARK-18193: - While according to my test result, QueueStream

[jira] [Commented] (SPARK-18193) queueStream not updated if rddQueue.add after create queueStream in Java

2016-11-04 Thread Sean Owen (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-18193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15635805#comment-15635805 ] Sean Owen commented on SPARK-18193: --- No, per the docs that isn't supported. The example

[jira] [Commented] (SPARK-18193) queueStream not updated if rddQueue.add after create queueStream in Java

2016-11-03 Thread Hubert Kang (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-18193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15635294#comment-15635294 ] Hubert Kang commented on SPARK-18193: - Is it possible to do that in opposite way, whi

[jira] [Commented] (SPARK-18193) queueStream not updated if rddQueue.add after create queueStream in Java

2016-11-03 Thread Sean Owen (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-18193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15634149#comment-15634149 ] Sean Owen commented on SPARK-18193: --- Oh I see, it's the opposite. The QueueStream examp

[jira] [Commented] (SPARK-18193) queueStream not updated if rddQueue.add after create queueStream in Java

2016-11-01 Thread Hubert Kang (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-18193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15627774#comment-15627774 ] Hubert Kang commented on SPARK-18193: - Thanks Sean. While it's inconsistent with tha