diff --git a/examples/src/main/java/org/apache/spark/examples/streaming/JavaCustomReceiver.java b/examples/src/main/java/org/apache/spark/examples/streaming/JavaCustomReceiver.java index 5622df5ce03ff21b7df7e778ef3fbcab50ad50ba..981bc4f0613a9036cbe30564638bb08552305be6 100644 --- a/examples/src/main/java/org/apache/spark/examples/streaming/JavaCustomReceiver.java +++ b/examples/src/main/java/org/apache/spark/examples/streaming/JavaCustomReceiver.java @@ -57,7 +57,7 @@ public class JavaCustomReceiver extends Receiver<String> { public static void main(String[] args) { if (args.length < 2) { - System.err.println("Usage: JavaNetworkWordCount <hostname> <port>"); + System.err.println("Usage: JavaCustomReceiver <hostname> <port>"); System.exit(1); }