flink 1.12的jdbc connector不支持 sink.parallism 参数,是不是说只能和上游cdc connector保持相同的并行度1?如果是的话,下游sink会有瓶颈,因为表中存有大量的历史数据,将存量数据同步到目标表需要花费不少时间,而新的业务数据也源源不断进来,导致追不上。这要如何解决? flink 1.13的jdbc connector新增 sink.parallism 参数,问题是如果增大并行度的话能否确保同一个主键记录发到同一个sink task呢?SQL正确的写法是什么?
- flink sql cdc数据同步至mysql casel.chen
- Re: flink sql cdc数据同步至mysql Leonard Xu
- Re:Re: flink sql cdc数据同步至mysql casel.chen
- Re:Re: flink sql cdc数据同步至mysql casel.chen
- Re:flink sql cdc数据同步至mysql 东东
- Re:Re:flink sql cdc数据同步至mysql casel.chen