Skip to content

APIError: error decoding response body when streaming query results using queryIter().stream() #664

@Shanmugavel-J

Description

@Shanmugavel-J

When executing a query using queryIter().stream() and transforming the results in chunks, I intermittently encounter the following error:

Error: APIError: error decoding response body

const rows = await conn.queryIter("SELECT * FROM test");
const stream = rows.stream();

const transformer = new Transform({
  readableObjectMode: true,
  writableObjectMode: true,
  transform(row, _, callback) {
    console.log(row.data()); **// Sometimes fails here**
    callback();
  },
});

stream.pipe(transformer);

Node.js version: 20.18.1
npm-databend-driver version: 0.28.1

Metadata

Metadata

Assignees

Labels

No labels
No labels

Type

No type

Projects

No projects

Milestone

No milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions