talatuyarer opened a new pull request, #29165: URL: https://github.com/apache/flink/pull/29165
When a `CatalogView`'s expanded query contains **unqualified** table references, the planner resolved them against the reader's **current session database** instead of the view's own catalog/database. The same view could then succeed in one session and fail in another. This is observable with external catalogs (e.g. Iceberg) that return portable, unqualified SQL from `CatalogView#getExpandedQuery()`. Root cause: `CatalogManager.resolveCatalogView` eagerly parses the expanded query with `parser.parse(...)` in the session context (introduced in FLINK-37098), which qualifies unqualified references against the current session database and bypasses the hermetic view-expansion path. -- 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]
