mchades opened a new pull request, #11237:
URL: https://github.com/apache/gravitino/pull/11237
### What changes were proposed in this pull request?
This PR fixes the Paimon Flink factory wiring in Gravitino:
- Change GravitinoPaimonCatalog#getFactory to delegate to the underlying
paimon catalog factory.
- Remove the now-unused FlinkTableFactory direct import.
### Why are the changes needed?
In the previous implementation, Gravitino returned a no-arg
FlinkTableFactory, which does not bind the concrete FlinkCatalog context.
For metastore.partitioned-table=true, this may break expected Hive Metastore
partition sync behavior in Flink path.
Fix: #9287
### Does this PR introduce _any_ user-facing change?
- For Flink + Paimon catalog usage, table factory behavior now aligns with
underlying Paimon catalog wiring.
- No user-facing API change.
- No property key addition/removal.
### How was this patch tested?
- Ran module compilation:
./gradlew :flink-connector:flink-common:compileJava
- Result: BUILD SUCCESSFUL
- No dedicated new test is added in this PR.
--
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]
