[ https://issues.apache.org/jira/browse/ARROW-9661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Liya Fan resolved ARROW-9661. ----------------------------- Resolution: Not A Bug > [Java] Failed to read arrow IPC streaming format > ------------------------------------------------ > > Key: ARROW-9661 > URL: https://issues.apache.org/jira/browse/ARROW-9661 > Project: Apache Arrow > Issue Type: Improvement > Components: Java > Affects Versions: 1.0.0 > Reporter: Haowei Yu > Assignee: Liya Fan > Priority: Critical > Attachments: arrowdata > > > I have some bytes, which are in IPC streaming format, but Java failed to read > data and give me back error > {code:java} > java.io.IOException: Expected schema but header was 0 > {code} > Here is my java code > {code:java} > BufferAllocator allocator = new RootAllocator(Long.MAX_VALUE); > ArrayList<ValueVector> valueVectors = new ArrayList<>(); > final ArrayList<List<ValueVector>> batchOfVectors = new ArrayList<>(); > final RootAllocator rootAllocator = new RootAllocator(); > InputStream inputStream = new FileInputStream("/tmp/arrowdata"); > try (ArrowStreamReader reader = new ArrowStreamReader(inputStream, > allocator); ) { > VectorSchemaRoot root = reader.getVectorSchemaRoot(); // <- IOException > thrown in the line > while (reader.loadNextBatch()) { > valueVectors = new ArrayList<>(); > for (FieldVector f : root.getFieldVectors()) > { > // transfer will not copy data but transfer ownership of memory > // from streamReader to resultChunk > TransferPair t = f.getTransferPair(rootAllocator); > t.transfer(); > valueVectors.add(t.getTo()); > } > batchOfVectors.add(valueVectors); > root.clear(); > } > }{code} > I am using arrow-vector 1.0.0 and I put my arrow data in the attachment. I am > pretty sure data is correct since I can read data using JS sdk. > I am willing to provide more information if you want. And I appreciate if > anyone can give me some guide on how to debug this ( Not sure if this is a > netty thing since I do have another version of netty as dependency in my > project ) -- This message was sent by Atlassian Jira (v8.3.4#803005)