Hubert Kang created SPARK-18193:
-----------------------------------
Summary: 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: Streaming
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: [email protected]
For additional commands, e-mail: [email protected]
