IPC writer silently writes a corrupt stream for a Table from another copy of apache-arrow
Los mantenedores suelen responder en 1 día
Evaluación
- Dificultad
- 3/5
- Tiempo estimado
- 1-2 días
- Aptitud para principiantes
- 68/100
- Tipo de issue
- Error
- Claridad
- Bien especificado
- Estado de actividad
- Activo
- Stack tecnológico
- node.js, typescript
Línea de trabajo
Start in src/visitor.ts at getVisitFn, where the issue identifies instanceof DataType checks as the cause; compare with DataType.isDataType() in src/type.ts. Add or update tests for cross-copy types and run the relevant visitor and IPC tests. Done means tables from separate CommonJS and ES module builds serialize with valid types and buffers and round-trip successfully.
Escrito por el modelo de indexación a partir del texto del issue.
Descripción
[!NOTE]
I discovered this issue and wrote it up with help from Claude Opus 5.5.
Describe the bug, including details regarding any error messages, version, and platform.
Since #377 (released in 21.2.0), instanceof Table accepts a Table created by another copy of apache-arrow. tableToIPC then serializes such a table without any error, but the Arrow IPC stream it writes is unusable: field types are missing or wrong, and the dictionary and record batch messages have empty bodies. None of the data is written.
An easy way to get two copies is the package's own CommonJS and ES module builds. Node loads them separately when, for example, an ES module application passes a table to a CommonJS library. Bundlers can do the same through the import and require conditions.
Reproduction
apache-arrow 21.2.0, Node.js 24.8.0, macOS:
// repro.mjs
import { createRequire } from "node:module";
import * as esm from "apache-arrow";
const cjs = createRequire(import.meta.url)("apache-arrow");
const table = esm.tableFromArrays({ id: Int32Array.from([1, 2]), text: ["a", "b"] });
console.log(esm.Table === cjs.Table, table instanceof cjs.Table); // false true
const crossBuild = cjs.tableToIPC(table, "stream"); // No error
const sameBuild = esm.tableToIPC(table, "stream");
console.log(crossBuild.length, sameBuild.length); // 440 648
esm.tableFromIPC(crossBuild);
// TypeError: Cannot destructure property 'length' of '(intermediate value)(intermediate value)(intermediate value)' as it is undefined.
// at .../apache-arrow/visitor/vectorloader.mjs:154
PyArrow 25.0.1 rejects the same crossBuild bytes with OSError: Invalid flatbuffers message. The sameBuild stream reads correctly in both.
Single-column tables fail in different ways. In each case the cross-build stream has empty message bodies:
| Column type | Same-build bodies | Cross-build bodies | PyArrow reading the cross-build stream |
|---|---|---|---|
Int32 |
batch: 8 bytes | batch: 0 bytes | ArrowNotImplementedError: Integers with less than 8 bits not implemented |
Float64 |
batch: 16 bytes | batch: 0 bytes | OSError: buffer_index out of range. |
Utf8 |
batch: 24 bytes | batch: 0 bytes | OSError: buffer_index out of range. |
Dictionary<Utf8, Int32> |
dictionary: 24, batch: 16 bytes | dictionary: 0, batch: 0 bytes | OSError: Unexpected null field DictionaryEncoding.indexType in flatbuffer-encoded metadata |
Cause
#377 added DataType.isDataType() for checks across copies, and deliberately did not give DataType a Symbol.hasInstance. But getVisitFn still dispatches on node instanceof DataType and node.type instanceof DataType. A type from another copy fails both checks and falls through to Type.NONE. As a result, TypeAssembler writes no type, and no indexType for a dictionary, and the writer emits no buffers. Nothing reports an error.
Suggested fix
Use the cross-copy check in getVisitFn:
- if (node && (node instanceof DataType)) {
+ if (node && DataType.isDataType(node)) {
return getVisitFnByTypeId(visitor, inferDType(node), throwIfNotFound);
}
- if (node?.type && (node.type instanceof DataType)) {
+ if (node?.type && DataType.isDataType(node.type)) {
return getVisitFnByTypeId(visitor, inferDType(node.type), throwIfNotFound);
}
I applied the equivalent change to visitor.js in the CommonJS build of 21.2.0. With it, the cross-build write in the reproduction round-trips, and its output is byte-identical to a same-build write. I also checked a table with an Int32 column and a Dictionary<Utf8, Int16> column: identical bytes, and PyArrow reads the result.
It may also be worth making the writer throw when a type can't be visited, rather than writing an empty body.
Related issues
#61, #377, #56
- Lenguaje dominante
- TypeScript
- Estrellas
- 112
- Forks
- 23
- Merge medio
- 4 h 13 min
- PR fusionados (30 d)
- 10
Preparar el entorno
- Incluye un Dockerfile o un archivo de Docker Compose
- Tiene una plantilla de pull request
- Leer la guía de contribución
Primeros pasos
- Lee el issue completo y luego la guía de contribución del proyecto.
- Comenta en el issue que vas a ocuparte — evita que dos personas hagan lo mismo.
- Haz un fork del repositorio y trabaja en una rama.
- Abre un pull request que haga referencia al número del issue.
Más de apache/arrow-js
-
RecordBatchReader on an open-ended async stream withholds each record batch until the next chunk arrivesPosiblemente ocupada @cpruijsen la tomó hace 2 días. Abierto
Dificultad 2/5 1-3 horas Aptitud para principiantes 84/100
Los mantenedores suelen responder en 1 día
-
`Data.valueOffsets` is longer than `length + 1` after an IPC round tripPosiblemente ocupada @kylebarron la tomó hace 23 días. Abierto
Dificultad 3/5 1-2 días Aptitud para principiantes 68/100
apache/arrow-js#484 · 1 comentario · 1 reacción ·
Los mantenedores suelen responder en 1 día
-
Dificultad 3/5 1-2 días Aptitud para principiantes 55/100
apache/arrow-js#468 · 2 comentarios ·
Los mantenedores suelen responder en 1 día
-
Dificultad 3/5 1-2 días Aptitud para principiantes 35/100
Los mantenedores suelen responder en 1 día
-
Dificultad 5/5 Más de una semana Aptitud para principiantes 35/100
apache/arrow-js#423 · 1 reacción ·
Los mantenedores suelen responder en 1 día
Todos los issues de apache/arrow-js
Issues similares
-
documentation good first issue
Dificultad 2/5 Medio día Aptitud para principiantes 72/100
sujithputta02/Esapay#13 ·
-
Share dialog: the address book's contact count reads "1 contacts" (no singular form in any language)Posiblemente ocupada @chibenwa la tomó hoy. Abiertoai-driven-qa bug claude Cosmetic
Dificultad 2/5 1-3 horas Aptitud para principiantes 72/100
linagora/twake-contacts-frontend#271 · 1 comentario ·
Los mantenedores suelen responder en 1 día
-
Dificultad 2/5 1-3 horas Aptitud para principiantes 72/100
Koenkk/zigbee2mqtt#33402 ·
Los mantenedores suelen responder en 1 día
-
dx P2 platform Stellar Wave Wave 10
Dificultad 2/5 1-3 horas Aptitud para principiantes 72/100
winsznx/routedock#579 · 1 comentario ·
Los mantenedores suelen responder en 1 día
-
area:ui effort:S enhancement priority:P2
Dificultad 2/5 1-3 horas Aptitud para principiantes 78/100
Los mantenedores suelen responder en 1 día