Hello, There is a streaming World Count example at the beginning of the Structured Streaming Programming Guide <https://spark.apache.org/docs/latest/structured-streaming-programming-guide.html> .
First, we execute *nc -lk 8888* in a separate terminal. Next, following the Python code, we have this in *example.py:* We test the application by: * spark-submit example.py * The application runs and waits for data on the socket. We type single words several times in the terminal running netcat, each time with carriage returns. The application is failing every time. Here is some (snipped) output: What is strange is the the exact same example works for other members of the team, using the same Python version (3.7.0) and the same Spark version (2.3.1). Has anyone seen similar behavior? Many thanks, Jonathan -- Sent from: http://apache-spark-user-list.1001560.n3.nabble.com/ --------------------------------------------------------------------- To unsubscribe e-mail: [email protected]
