NiFi header 索引超出范围

NiFi header index out of range

我正在将竖线分隔的文本文件转换为 parquet。为此,我正在使用转换记录处理器。

Reader-csv reader

writer-ParquetSetWriter.

模式策略- reader 中的 InferSchema 并继承 writer 中的记录模式。

但我在 ConvertRecord 处理器中遇到错误。它说 header“ColumnName”的索引是 24,但只有 24 个值。

根据提供的输入,由于一组值分隔不当,您的一行似乎有 25 个值。 “在索引 24 上,但只有 24 个值”意味着您位于偏移量 0 的第 25 位。

要调试它,如果它是一个非常大的 CSV 文件,您可以将 SplitRecordValidateRecord 链接在一起以尝试捕获有此问题的行。