apache-spark - 用于 Spark 结构化流的 Qubole Kinesis 连接器引发错误

Question

我们正在使用 Qubole Kinesis 连接器 (jar) 进行 Spark 结构化流式传输。这曾经可以正常工作，但突然间，它抛出错误“未找到 S3 文件系统”。

我们可以使用 KCL，但我们需要针对 foreachbatch 对其进行测试。是否有任何其他可用的 Kinesis 连接器可提供无缝写入操作？

Answer 1

@Lightning-Analytics，请分享完整的堆栈跟踪和相应的 qubole 流命令 ID（如果有）。