我正在通过flink读取csv文件。csv文件有特定的列数。
我已经定义了

RowCsvInputFormat format = new RowCsvInputFormat(filePath, 
            new TypeInformation[]{  
            BasicTypeInfo.STRING_TYPE_INFO,
            BasicTypeInfo.STRING_TYPE_INFO,
            BasicTypeInfo.STRING_TYPE_INFO,
            BasicTypeInfo.STRING_TYPE_INFO
    });

如果文件中的所有行都有适当的4列，那么代码工作正常。
我想处理这样一种情况：文件中的几行没有4列，或者几行中存在任何其他问题。
我怎样才能在Flink做到这一点。