chl-wxp commented on issue #10339:
URL: https://github.com/apache/seatunnel/issues/10339#issuecomment-3752662746
flowchart TD
A[Start: Parse Job Config] --> B{Source has schema_url or schema_path?}
B -- No --> C[Use legacy local schema config<br/>schema { fields { ... } }
/ connector default]
C --> Z[Submit Job]
B -- Yes --> D[Resolve Metalake Config]
D --> D1[Priority: env metalake_*]
D1 --> D2[Else: OS env metalake_*]
D2 --> D3[Else: connector metalake_type/metalake_url]
D3 --> E{schema_url provided?}
E -- Yes --> F[FinalSchemaUrl = schema_url]
E -- No --> G[Parse schema_path: catalog.schema.table]
G --> H{metalake_url resolvable?}
H -- No --> H1[Fail: missing metalake_url for schema_path]
H -- Yes --> I[Build FinalSchemaUrl = metalake_url + catalog + /schemas/ +
schema + /tables/ + table]
F --> J[Select detector by metalake_type]
I --> J
J --> K{Detector exists?}
K -- No --> K1[Fail: unknown metalake_type]
K -- Yes --> L[HTTP GET FinalSchemaUrl]
L --> M{HTTP OK?}
M -- No --> M1[Fail: HTTP error / timeout]
M -- Yes --> N[Parse response body]
N --> O{Mapping success?}
O -- No --> O1[Fail: parse/type mapping error]
O -- Yes --> P[Build CatalogTable / SeaTunnel schema]
P --> Q[Inject resolved schema into source runtime config]
Q --> Z[Submit Job]
--
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]
