使用flink connect 发现SR数据有重复