CsvTableSource error handling

[Athar Naved]

Hi There,

I am trying to parse multiple csv files in a directory using CsvTableSource and insert each row into cassandra using CassandraSink.

How does flink handle any errors to parse some of the csv files within that directory?

--