[I] [Bug] [mongodb-cdc] mongo-cdc cannot dynamically add new tables [seatunnel]

[via GitHub]

jw-itq opened a new issue, #8870:
URL: https://github.com/apache/seatunnel/issues/8870

   ### Search before asking
   
   - [x] I had searched in the 
[issues](https://github.com/apache/seatunnel/issues?q=is%3Aissue+label%3A%22bug%22)
 and found no similar issues.
   
   
   ### What happened
   
   When using mongo-cdc connector in incremental mode, the connector fails to 
properly handle new tables added after a savepoint.
   Steps to Reproduce
   
   1.Start a mongo-cdc synchronization job to JDBC in incremental mode
   2.Stop the job using savepoint
   3.Add new tables to the configuration file
   4.Restart the job using the previous jobid
   5.Check logs and target database - only data from the last table in the 
configuration is being synchronized
   
   ### SeaTunnel Version
   
   dev
   
   ### SeaTunnel Config
   
   ```conf
   env {
     parallelism = 1
     job.mode = "STREAMING"
     checkpoint.interval = 1000
   }
   
   source {
     MongoDB-CDC {
       hosts = "mongo0:27017"
       database = ["inventory"]
       collection = ["inventory.address_hangzhou"]
       username = superuser
       password = superpw
       tables_configs = [
         {
           schema {
             table = "inventory.address_hangzhou"
             primaryKey {
               name = "id"
               columnNames = ["_id"]
             }
             fields {
               "_id": string,
               "cid": long,
               "country": string,
               "city": string,
               "detail_address": string
             }
           }
         }
       ]
     }
   }
   
   sink {
     jdbc {
       url = "jdbc:mysql://mysql_e2e:3306/mongodb_cdc"
       driver = "com.mysql.cj.jdbc.Driver"
       user = "st_user"
       password = "seatunnel"
       generate_sink_sql = true
       # You need to configure both database and table
       database = mongodb_cdc
       table = "${table_name}"
       primary_keys = ["_id"]
     }
   }
   ```
   
   ### Running Command
   
   ```shell
   seatunnel.sh -c mongodb-cdc-to-jdbc.conf -r 55555555
   ```
   
   ### Error Exception
   
   ```log
   -
   ```
   
   ### Zeta or Flink or Spark Version
   
   zeta
   
   ### Java or Scala Version
   
   jdk1.8
   
   ### Screenshots
   
   <img width="1182" alt="Image" 
src="https://github.com/user-attachments/assets/7d97d36f-fb8b-4334-af5a-996f10ae7498";
 />
   
   ### Are you willing to submit PR?
   
   - [ ] Yes I am willing to submit a PR!
   
   ### Code of Conduct
   
   - [x] I agree to follow this project's [Code of 
Conduct](https://www.apache.org/foundation/policies/conduct)
   


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscr...@seatunnel.apache.org.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org