Kafka连接HDFS接收器错误无法创建WAL

Question

我正在使用 Kafka 连接 HDFS。当我尝试运行连接器时，出现以下异常：

错误无法创建 WAL 编写器：无法为客户端 [IP] 的 [DFSClient_NONMAPREDUCE_208312334_41] 创建文件 [/path/log]，因为该文件已由 [DFSClient_NONMAPREDUCE_165323242_41] 创建

请问有什么建议吗？

Answer 1

根据进一步测试，将版本升级到 2.7.7 没有帮助。我们仍然遇到了 WAL 问题。我们最终使用了不同的接收器 s3SinkConnector。