有了这个Flink CDC，已经到增量阶段了，为啥数据库的processlist还是没减少，并行度？

有了这个Flink CDC，已经到增量阶段了，为啥数据库的processlist还是没减少，并行度是4， 到增量阶段，理论上数据库的process list应该是1， 对吧？// 节省资源
Properties debeziumProperties = new Properties();
debeziumProperties.setProperty("scan.incremental.close-idle-reader.enabled", "true");return new MySqlSourceBuilder()
.hostname(hostPortPair.getLeft())
.port(Integer.parseInt(hostPortPair.getRight()))
.databaseList(databaseTablePair.getLeft())
.tableList(databaseTablePair.getRight())
.username(fromDatabaseSetting.getUserName())
.serverTimeZone(DEFAULT_TIME_ZONE)
.jdbcProperties(jdbcProperties)
.debeziumProperties(debeziumProperties)
.serverId(drsSetting.getServerIdRange())
.password(fromDatabaseSetting.getPassword())
.deserializer(new ChangeRecordDebeziumDeserializationSchema()
.setDrsSetting(drsSetting)
.setOptions(options)
.setDingTalkManager(dingTalkManager)
.setDrsJobManager(drsJobManager))
.startupOptions(startupOptions)
.scanNewlyAddedTableEnabled(true)
// 忽略DDL事件
.includeSchemaChanges(false)
.build();