[ https://issues.apache.org/jira/browse/SPARK-18193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Hubert Kang reopened SPARK-18193: --------------------------------- While it's inconsistent with that in QueueStream.scala. something is pushed to the queue after ssc.start() and could be recognized successfully. It's expected so that live data stream could be handled. > queueStream not updated if rddQueue.add after create queueStream in Java > ------------------------------------------------------------------------ > > Key: SPARK-18193 > URL: https://issues.apache.org/jira/browse/SPARK-18193 > Project: Spark > Issue Type: Bug > Components: DStreams > Affects Versions: 2.0.1 > Reporter: Hubert Kang > > Within > examples\src\main\java\org\apache\spark\examples\streaming\JavaQueueStream.java, > no any data is deteceted if below code to put something to rddQueue is > executed after queueStream is created (line 65). > for (int i = 0; i < 30; i++) { > rddQueue.add(ssc.sparkContext().parallelize(list)); > } -- This message was sent by Atlassian JIRA (v6.3.4#6332) --------------------------------------------------------------------- To unsubscribe, e-mail: issues-unsubscr...@spark.apache.org For additional commands, e-mail: issues-h...@spark.apache.org