We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 3e2492b commit 331ecceCopy full SHA for 331ecce
examples/src/main/python/streaming/stateful_network_wordcount.py
@@ -39,7 +39,7 @@
39
if len(sys.argv) != 3:
40
print >> sys.stderr, "Usage: stateful_network_wordcount.py <hostname> <port>"
41
exit(-1)
42
- sc = SparkContext(appName="PythonStreamingNetworkWordCount")
+ sc = SparkContext(appName="PythonStreamingStatefulNetworkWordCount")
43
ssc = StreamingContext(sc, 1)
44
ssc.checkpoint("checkpoint")
45
0 commit comments