nzw921rx opened a new pull request, #12234: URL: https://github.com/apache/seatunnel/pull/12234
### Purpose of this pull request AerospikeSinkFactory and SlsSinkFactory implement TableSinkFactory, but their created sinks inherited the default getWriteCatalogTable implementation, which returns Optional.empty. As a result, the engine cannot resolve the configured sink table metadata and falls back to the default table path. This patch: - Preserves the CatalogTable in AerospikeSink and SlsSink. - Returns the configured table from getWriteCatalogTable. - Passes the complete CatalogTable from SlsSinkFactory while continuing to derive the writer row type from it. ### Does this PR introduce any user-facing change? Yes. Aerospike and SLS sinks now expose the configured catalog table to the engine instead of reporting no write table. Connector configuration and data-writing behavior are unchanged. ### How was this patch tested? - ./mvnw spotless:apply - git diff upstream/dev...HEAD --check No new dependencies, configuration options, or documentation changes are introduced. ### Check list * [x] No new Jar binary package is added. * [x] Documentation changes are not necessary because no connector option or documented behavior changes. * [x] incompatible-changes.md changes are not necessary because this is backward compatible. * [x] Connector packaging and E2E metadata changes are not necessary because no new connector is added. -- 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]
