星火室壁运动流例如
问题描述:
运行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示例?
非常感谢您的回复。通过反复试验,终于明白每个碎片都需要存在两张牌。 (火花文档中丢失的重要细节) –