goutamadwant opened a new pull request, #12247: URL: https://github.com/apache/seatunnel/pull/12247
### Purpose of this pull request Part of #10425, limited to the existing InfluxQL source connector. Add `tables_configs` so one source can read multiple queries and databases with independent output schemas. Route splits and rows by catalog table identity, and map returned series columns to the appropriate schema. ### Does this PR introduce _any_ user-facing change? Yes. Previously, a configuration containing only `tables_configs` failed validation because root-level query and schema configuration was required. Different queries or schemas needed separate source definitions. Each entry now defines `sql`, `schema.table`, and `schema.fields`, with a per-table database or a shared root default. Empty results do not prevent other tables from being read. In the new mode, query errors fail the read instead of appearing as empty data. Existing single-table configuration and legacy split deserialization are retained. New-mode integer partitions cover inclusive bounds without overlap. Partitioned entries support simple SELECT queries; complex queries, including `tz(...)`, remain available without partition options. Switching between single-table and multi-table mode requires a fresh job. The client dependency and legacy partition behavior are unchanged. ### How was this patch tested? - Reproduced the missing feature on unchanged code with Java 8 and Java 11. - Passed 39 connector tests on each JDK, covering validation, column mapping, empty/error results, partition boundaries, reordered restore, and legacy splits. - Passed two real InfluxDB 1.8.10 integration tests on each JDK, covering separate databases and schemas, uneven partitions, empty results, restored table identities, and legacy timezone queries. - Passed the new engine E2E fixture on Zeta with Java 8 and per-table Assert checks. - Passed scoped Spotless checks and `git diff --check`. - Passed the full repository `mvn -o -q -DskipTests verify` build on Java 11. 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]
