[
https://issues.apache.org/jira/browse/SPARK-11642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sean Owen resolved SPARK-11642.
-------------------------------
Resolution: Invalid
Please use [email protected] for questions rather than JIRA.
> networkcount is not working using my stream source
> --------------------------------------------------
>
> Key: SPARK-11642
> URL: https://issues.apache.org/jira/browse/SPARK-11642
> Project: Spark
> Issue Type: Question
> Reporter: Amir Rahnama
>
> My small nodejs stream source writes some words to socket port 8000 but spark
> streaming example, Network Word Count is not reading that data. Can you guys
> help me?
> var net = require('net'),
> EXEC_INTERVAL = 1000,
> words = ['I', 'You', 'He', 'She', 'It', 'We', 'You', 'They'],
> server = net.createServer(function(socket) {
> setInterval(function() {
> var index = Math.floor((Math.random() * 7) + 1);
> socket.write(words[index] + ' ' + words[index - 1]);
> }, EXEC_INTERVAL);
> }).listen(8000);
> this is the stream and nc localhost 8000 is showing me the result of socket
> write but Spark is not getting it.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
