Program:
create table "foo.bar" (x int) with (
'connectors' = '[{
"transport": {
"name": "file_input",
"config": {
"path": "/path/to/file.csv"
}
},
"format": {
"name": "csv",
"config": {}
}
}]'
)where file.csv contains some lines that cause parser errors, e.g.,
Start the pipeline. The webconsole reports two parser errors, however clicking on the error counter causes the following error in the log:
[dot] 2026-03-24T22:32:12.408375Z ERROR dbsp_adapters::server::error: [HTTP error response] UnknownInputEndpoint: unknown input endpoint name 'foo.bar.bar.unnamed-0'
[dot] 2026-03-24T22:32:12.408590Z ERROR dbsp_adapters::server: Response: 404 Not Found (size: Sized(153)) to request GET /input_endpoints/foo.bar.bar.unnamed-0/stats
Program:
where
file.csvcontains some lines that cause parser errors, e.g.,Start the pipeline. The webconsole reports two parser errors, however clicking on the error counter causes the following error in the log: