You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@spark.apache.org by "Lutz Buech (JIRA)" <ji...@apache.org> on 2015/01/14 18:09:35 UTC
[jira] [Created] (SPARK-5252) Streaming StatefulNetworkWordCount
example hangs
Lutz Buech created SPARK-5252:
---------------------------------
Summary: Streaming StatefulNetworkWordCount example hangs
Key: SPARK-5252
URL: https://issues.apache.org/jira/browse/SPARK-5252
Project: Spark
Issue Type: Bug
Components: Streaming
Affects Versions: 1.2.0
Environment: Ubuntu Linux
Reporter: Lutz Buech
Running the stateful network word count example in Python (on one local node):
https://github.com/apache/spark/blob/master/examples/src/main/python/streaming/stateful_network_wordcount.py
At the beginning, when no data is streamed, empty status outputs are generated, only decorated by the current Time, e.g.:
-------------------------------------------
Time: 2015-01-14 17:58:20
-------------------------------------------
-------------------------------------------
Time: 2015-01-14 17:58:21
-------------------------------------------
As soon as I stream some data via netcat, no new status updates will show. Instead, one line saying
[Stage <number>:====================================================> (2 + 0) / 3]
where <number> is some integer number, e.g. 132. There is no further output on stdout.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscribe@spark.apache.org
For additional commands, e-mail: issues-help@spark.apache.org