dask - dask 数据帧 to_parquet 抛出错误

Question

我正在尝试将任务数据帧保存到 HDFS 上的镶木地板上。但是它失败并出现错误：Exception: TypeError('expected list of bytes',)

我还将 object_encoding 参数提供为 {"anomaly":"json","sensor_name":"json"}。

这是数据框中的列： Index(['original_value', 'anomaly', 'anomaly_bin', 'sensor_name'], dtype='object')

列 sensor_name 和 anomaly 是字符串。其他列是浮动的。

例如：[18.0 'N' 0.0 'settemp']

我还尝试将其保存为 HDFS 中的 CSV，但 api 失败并出现错误：异常：ValueError（'url 类型不理解：CSV 的路径为：hdfs://ip:port/some path

如果有人能引导我朝着正确的方向前进，那就太好了。