flink 写入 starrocks 报错 too many filtered rows attachment

可能原因1

把你starrocks中DDL里的varchar(...) 先修改为STRING.  一般是因为字段超出定义的长度.

可能原因  插入的数据 某列为空,但是该列不允许为null

mini load：too many filtered rows · Issue #1815 · apache/doris · GitHub 

可能原因2

csv里有脏数据 导致3列被切分为4列

....
    PRIMARY KEY (`id`) NOT ENFORCED
) WITH (
    'connector' = 'starrocks',
    'jdbc-url' = '...',
    'username' = '...',
    'password' = '...',
    'database-name' = 'db1',
    'load-url' = '...',
    'table-name' = 'table1',
-- 加上下面三行  尤其最后两行
    'sink.properties.format' = 'csv',
    'sink.properties.column_separator' = '\x01',
    'sink.properties.row_delimiter' = '\x02'
)