在使用熊猫1.1.5和py箭头2.0.0运行pyspark3时,会出现以下错误:import pyarrow at org.apache.arrow.vector.ipc.message.MessageSerializer.serialize(MessageSerializer.java:165)
at org.apache.arrow.vector.ipc.A
由于现有的代码结构,如下所示:// Pass buffer to a remote method, which MIGHT write我没有在java中找到任何带有脏标志的缓冲区实现。在所有这些情况下,我的代码已经在ByteBuffers中传递了,为了添加这个脏标志,我应该:
简单地用脏标志包装ByteBuffer