星火室壁运动流例如

Question

运行https://github.com/apache/spark/blob/master/extras/kinesis-asl/src/main/java/org/apache/spark/examples/streaming/JavaKinesisWordCountASL.java

我遇到的问题我修改这个例子，用我自己的值“应用程序名称”，“流名称”和“端点URL”。

我在我的代码中放置了各种打印行。使用cmd“spark-submit”运行作业时，我无法在stdout日志中看到任何打印行。

有人可以请我解释一下，我可以在哪里找到打印系统。为什么我没有看到stdout日志？

是否有人能够成功运行该Java示例？

Answer 1

你是否与本地主人一起运行？如果是这样，你看看这个帖子吗？ Apache Spark Kinesis Sample not working

基本上，每个分片需要两个核心。