FlinkCDC能读取到快照，但是无法输出更新数据
发现是并行度问题，当我的并行度超过1的时候就无法捕获更新。

public static void main(String[] args) throws Exception {System.setProperty("HADOOP_USER_NAME", "lcq");Configuration conf = new Configuration();conf.setInteger("rest.port", 2000);StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();env.setParallelism(4);MySqlSource<String> mySqlSource = MySqlSource.<String>builder().hostname("Master").port(3306).databaseList("test") // set captured database.tableList("test.cart_info") // set captured table.username("root").password("123456").deserializer(new StringDebeziumDeserializationSchema()) // converts SourceRecord to JSON String.startupOptions(StartupOptions.initial()).build();// TODO 使用CDC Source从MySQL读取数据DataStreamSource<String> mysqlDS =env.fromSource(mySqlSource,WatermarkStrategy.noWatermarks(),"MysqlSource").setParallelism(1);mysqlDS.print();env.execute();}```