这可能与您拥有多少个工作者线程有关。使用–master local
[2]运行应用程序时，我遇到了同样的问题。我花了很多时间寻找答案，却一无所获。出于好奇，我改用–master local
[4]并成功了。我不知道根本原因。也许更熟悉Spark的人可以启发我们。
注意：就我而言，我的Kinesis流有两个分片。因此，该应用创建了两个输入流，每个分片一个。
这可能与您拥有多少个工作者线程有关。使用–master local
[2]运行应用程序时，我遇到了同样的问题。我花了很多时间寻找答案，却一无所获。出于好奇，我改用–master local
[4]并成功了。我不知道根本原因。也许更熟悉Spark的人可以启发我们。
注意：就我而言，我的Kinesis流有两个分片。因此，该应用创建了两个输入流，每个分片一个。
名师互学网 版权所有 (c)2021-2022 ICP备案号：晋ICP备2021003244-6号
