0

从这里我了解到我需要覆盖在 pyspark 中运行的应用程序的故障转移时间值，因为我遇到了很多“僵尸”工作人员。但是，通过阅读本教程，不清楚我应该将属性文件放在哪里。另外，我正在使用 pyspark 库中的 KinesisUtils，它不像自定义 KCL 使用者。

所以我的问题是，当通过 kinesis 运行火花流时，我应该如何更改 KCL 的配置？

4

0 回答 0