Skip to content

Commit 9cd2e3b

Browse files
committed
Fix row limit for structs
1 parent 543eba0 commit 9cd2e3b

File tree

2 files changed

+6
-3
lines changed

2 files changed

+6
-3
lines changed

package.json

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -27,12 +27,12 @@
2727
"typecheck": "tsc"
2828
},
2929
"devDependencies": {
30-
"@types/node": "20.14.8",
31-
"@typescript-eslint/eslint-plugin": "7.13.1",
30+
"@types/node": "20.14.9",
31+
"@typescript-eslint/eslint-plugin": "7.14.1",
3232
"@vitest/coverage-v8": "1.6.0",
3333
"eslint": "8.57.0",
3434
"eslint-plugin-import": "2.29.1",
35-
"eslint-plugin-jsdoc": "48.3.0",
35+
"eslint-plugin-jsdoc": "48.4.0",
3636
"http-server": "14.1.1",
3737
"hyparquet-compressors": "0.1.4",
3838
"typescript": "5.4.5",

src/column.js

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -98,6 +98,9 @@ export function readColumn(reader, rowLimit, columnMetadata, schemaPath, { compr
9898
if (rowData.length < rowLimit) {
9999
throw new Error(`parquet row data length ${rowData.length} does not match row group limit ${rowLimit}}`)
100100
}
101+
if (rowData.length > rowLimit) {
102+
rowData.length = rowLimit // truncate to row limit
103+
}
101104
return rowData
102105
}
103106

0 commit comments

Comments
 (0)