goutamadwant opened a new pull request, #12246: URL: https://github.com/apache/seatunnel/pull/12246
### Purpose of this pull request Part of #10425, limited to the existing IoTDB source connector. Add `tables_configs` so one source can read multiple queries with independent schemas and optional time partitions. Carry catalog table identities in splits and emitted rows for downstream routing. ### Does this PR introduce _any_ user-facing change? Yes. Previously, a configuration containing only `tables_configs` failed validation because root-level `sql` and `schema` were required. Each query needed a separate source definition. The new configuration accepts entries containing `sql`, `schema.table`, and `schema.fields`. It rejects duplicate identities, mixed root/per-table settings, and misplaced connection options before connecting. Existing single-table configuration and legacy split deserialization are retained. New-mode time partitions cover inclusive bounds without overlap. Partitioned entries support simple SELECT queries; complex queries remain available without partition options. Switching between single-table and multi-table mode requires a fresh job. IoTDBv2 is unchanged. ### How was this patch tested? - Reproduced the missing feature on unchanged code with Java 8 and Java 11. - Passed 40 connector tests on each JDK, covering validation, routing, partition boundaries, serialization, reordered restore, and legacy compatibility. - Passed real IoTDB 0.13.1 integration on Java 8 and Java 11, covering distinct schemas, 101 nonduplicated partitioned rows, and legacy reads. - Passed the new engine E2E fixture on Zeta with Java 8, parallel source readers, and per-table Assert checks. - Passed scoped Spotless checks and `git diff --check`. - Passed the full repository `./mvnw -q -DskipTests verify` build on Java 8. Tests were executed separately as listed above. The full engine test matrix was not run locally. ### Check list - [x] No new third-party runtime dependencies or license/notice changes. - [x] Updated English and Chinese connector documentation. - [x] Existing single-table configuration remains compatible; no incompatible-changes entry is required. - [x] Added connector E2E coverage. - [x] Existing plugin mapping, distribution registration, CI labels, and plugin configuration already cover this connector. -- 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: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
