把json换成csv试试
换成CSV需要修改实体等其他地方吗？json格式不行？
我试了下，应该不是格式的问题，是代码处理的问题应该，方便远程吗？开个腾讯会议
用我的代码 你复现不了吗？
这个问题我会看一下，但是好奇问一下过滤为什么不在flink里直接做掉，而是要放到starrocks里？在starrocks里过滤会多传输一些数据，而且flink本身就是一个计算引擎
是的，会在flink把不符合要求的数据过滤掉；但有条数据字节太长了导致输出到表中变成了null，而刚好这个字段设置了不允许为null，因此数据sink失败了；开始定位问题的时候以为是没有把null的数据过滤掉，因此想用starrocks的where再加一层过滤，然后就发现不生效。
所以具体到你的问题解决办法是设置varchar(65533)是吗，where虽然也是一个问题，但其实对解决你的问题不影响对吧？
另外你的flink-starrocks-connector是什么版本
是的，where不影响。connector版本：1.2.3_flink-1.15
好的，我看一下where的问题
这个问题后面哟解决吗？