fix

Author: czy006

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/io/debezium/connector/mysql/MySqlDatabaseSchema.java

@@ -409,12 +409,8 @@ public boolean storeOnlyCapturedTables() {
    *         connector's configuration
    */
   public boolean assignTableNumber(long tableNumber, TableId id) {
-    if (!isTableIncluded("assignTableNumber",id)) {
-      excludeTableIdsByTableNumber.put(tableNumber, id);
-      return false;
-    }
     final TableSchema tableSchema = schemaFor(id);
-    if (tableSchema == null) {
+    if (tableSchema == null && !isTableIncluded("assignTableNumber",id)) {
       excludeTableIdsByTableNumber.put(tableNumber, id);
       return false;
     }