This is an automated email from the ASF dual-hosted git repository.
jerryshao pushed a change to branch cherry-pick-b748d734-to-branch-1.3
in repository https://gitbox.apache.org/repos/asf/gravitino.git
from 9aa6560fcf fix(jdbc): correct schema drop resource verification
add 2c63b2bbf0 [Cherry-pick to branch-1.3] [#14014] fix(core): keep job
status polling and staging cleanup running after a failure (#14016) (#14072)
add 8c78d1b836 [Cherry-pick to branch-1.3] [#14029] fix(core): Expose
inferred credential-providers in catalog properties (#14030) (#14070)
add ad104ca711 [Cherry-pick to branch-1.3] [#13967] fix(spark-connector):
Reject Kerberos for routed Iceberg REST catalogs (#13968) (#14034)
add a42a73f859 [Cherry-pick to branch-1.3] [#13973][#13974]
fix(catalog-jdbc): Escape column default literals and table properties (#13975)
(#14104)
add 6644e1618a [Cherry-pick to branch-1.3] [#13978] fix(catalog-jdbc):
Keep column default value when updating column type (#13979) (#14068)
add 57c3df0ba8 [Cherry-pick to branch-1.3] [#14125]
improvement(trino-connector): Clarify that Iceberg REST routing requires OAuth2
(#14126) (#14188)
add 29749776d9 [Cherry-pick to branch-1.3] [#14039] fix(core): Return
consistent conflicts for metadata renames (#14040) (#14137)
add 6a9931414e [Cherry-pick to branch-1.3] [#14062][#14063]
fix(starrocks): Quote rename column names and skip empty alter clauses (#14064)
(#14134)
add 77b164ebbe [Cherry-pick to branch-1.3] [#14031] fix(flink-connector):
Validate credential providers for Iceberg non-REST backends (#14032) (#14132)
add 9ba4ef09d9 [Cherry-pick to branch-1.3] [#14048] fix(catalog-jdbc):
Clear comment when updating with null (#14053) (#14133)
add 34db649643 [Cherry-pick to branch-1.3] [#14022] fix(core): Honor the
declared mode of event listeners registered in code (#14023) (#14193)
add 466e56390b [Cherry-pick to branch-1.3] [#14073] fix(catalog-jdbc):
Quote reference column when updating column position (#14075) (#14136)
add 3631f0d586 [Cherry-pick to branch-1.3] [#14066] fix(starrocks): Map
index types when loading StarRocks tables (#14067) (#14199)
add bdb0b2ad3e [Cherry-pick to branch-1.3] [#14056] fix(catalog-jdbc):
Allow changing nullable column without default to NOT NULL (#14057) (#14195)
add c50d5e60fc Merge branch 'branch-1.3' into
cherry-pick-b748d734-to-branch-1.3
No new revisions were added by this update.
Summary of changes:
.../org/apache/gravitino/SupportsCatalogs.java | 3 +-
.../org/apache/gravitino/SupportsMetalakes.java | 3 +-
.../org/apache/gravitino/file/FilesetCatalog.java | 3 +-
.../org/apache/gravitino/model/ModelCatalog.java | 3 +-
.../apache/gravitino/policy/PolicyOperations.java | 3 +-
.../org/apache/gravitino/rel/TableCatalog.java | 3 +-
.../org/apache/gravitino/rel/indexes/Index.java | 9 +-
.../operations/ClickHouseTableOperations.java | 41 +-
.../operations/TestClickHouseTableOperations.java | 80 +++-
.../TestClickHouseTableOperationsUnit.java | 75 ++++
.../HologresColumnDefaultValueConverter.java | 15 +-
.../operation/HologresTableOperations.java | 4 +-
.../TestHologresColumnDefaultValueConverter.java | 27 ++
.../operation/TestHologresTableOperations.java | 12 +
.../operation/OceanBaseTableOperations.java | 39 +-
.../operation/TestOceanBaseTableOperations.java | 145 ++++++-
.../TestOceanBaseTableOperationsSqlGeneration.java | 9 +
.../catalog/fileset/FilesetCatalogOperations.java | 18 +-
.../fileset/TestFilesetCatalogOperations.java | 41 ++
.../converter/JdbcColumnDefaultValueConverter.java | 33 +-
.../jdbc/operation/JdbcTableOperations.java | 65 +++-
.../catalog/jdbc/TestJdbcCatalogCredential.java | 4 +
.../TestJdbcColumnDefaultValueConverter.java | 45 +++
.../jdbc/operation/TestJdbcTableOperations.java | 65 ++++
.../DorisColumnDefaultValueConverter.java | 87 +++++
.../doris/operation/DorisDatabaseOperations.java | 17 +-
.../doris/operation/DorisTableOperations.java | 178 ++++++++-
.../gravitino/catalog/doris/utils/DorisUtils.java | 8 +-
.../TestDorisColumnDefaultValueConverter.java | 52 +++
.../doris/integration/test/CatalogDoris2xIT.java | 44 +++
.../doris/integration/test/CatalogDoris3xIT.java | 45 +++
.../doris/integration/test/CatalogDoris4xIT.java | 45 +++
.../operation/TestDorisDatabaseOperations.java | 19 +
.../TestDorisDatabasePropertiesOperations.java | 96 +++++
.../doris/operation/TestDorisTableOperations.java | 129 +++++++
.../TestDorisTableOperationsSqlGeneration.java | 421 ++++++++++++++++++++-
.../catalog/doris/utils/TestDorisUtils.java | 35 ++
.../mysql/operation/MysqlTableOperations.java | 43 +--
.../mysql/operation/TestMysqlTableOperations.java | 183 ++++++++-
.../TestMysqlTableOperationsSqlGeneration.java | 9 +
.../PostgreSqlColumnDefaultValueConverter.java | 15 +-
.../operation/PostgreSqlTableOperations.java | 24 +-
.../TestPostgreSqlColumnDefaultValueConverter.java | 65 ++++
.../integration/test/CatalogPostgreSqlIT.java | 2 +-
.../operation/TestPostgreSqlTableOperations.java | 154 ++++++++
...TestPostgreSqlTableOperationsSqlGeneration.java | 13 +
.../operations/StarRocksTableOperations.java | 76 +++-
.../catalog/starrocks/utils/StarRocksUtils.java | 22 +-
.../operation/TestStarRocksTableOperations.java | 191 ++++++++++
.../TestStarRocksTableOperationsSqlGeneration.java | 136 ++++++-
.../starrocks/utils/TestStarRocksUtils.java | 54 +++
.../catalog/model/ModelCatalogOperations.java | 15 +-
.../catalog/model/TestModelCatalogOperations.java | 34 ++
.../gravitino/api/rel/indexes/index.py | 9 +
.../tests/unittests/dto/rel/test_index_serdes.py | 18 +
.../java/org/apache/gravitino/GravitinoEnv.java | 27 +-
.../apache/gravitino/catalog/CatalogManager.java | 14 +-
.../gravitino/catalog/ManagedTableOperations.java | 15 +-
.../apache/gravitino/connector/BaseCatalog.java | 10 +
.../job/BuiltInJobTemplateEventListener.java | 177 ++++++++-
.../java/org/apache/gravitino/job/JobManager.java | 176 +++++----
.../gravitino/listener/AsyncQueueListener.java | 48 ++-
.../org/apache/gravitino/listener/EventBus.java | 18 +-
.../gravitino/listener/EventListenerManager.java | 109 +++---
.../apache/gravitino/metalake/MetalakeManager.java | 13 +-
.../org/apache/gravitino/policy/PolicyManager.java | 16 +-
.../java/org/apache/gravitino/tag/TagManager.java | 8 +-
.../org/apache/gravitino/utils/RenameUtils.java | 51 +++
.../apache/gravitino/TestGravitinoEnvShutdown.java | 104 +++++
.../apache/gravitino/audit/DummyAuditWriter.java | 7 +-
.../apache/gravitino/audit/TestAuditManager.java | 28 ++
...ava => TestBaseCatalogCredentialProviders.java} | 87 ++---
.../job/TestBuiltInJobTemplateEventListener.java | 184 ++++++++-
.../org/apache/gravitino/job/TestJobManager.java | 237 ++++++++++++
.../gravitino/listener/TestAsyncQueueListener.java | 120 ++++++
.../listener/TestEventListenerManager.java | 206 ++++++++++
.../apache/gravitino/policy/TestPolicyManager.java | 27 ++
.../storage/relational/TestRenameConflicts.java | 309 +++++++++++++++
.../org/apache/gravitino/tag/TestTagManager.java | 32 ++
.../apache/gravitino/utils/TestRenameUtils.java | 63 +++
docs/flink-connector/flink-catalog-iceberg.md | 9 +
docs/jdbc-starrocks-catalog.md | 10 +-
docs/open-api/models.yaml | 9 +
docs/open-api/policies.yaml | 9 +
docs/security/credential-vending.md | 6 +-
docs/spark-connector/spark-catalog-iceberg.md | 2 +
docs/trino-connector/installation.md | 5 +
.../connector/iceberg/GravitinoIcebergCatalog.java | 91 ++++-
.../iceberg/IcebergPropertiesConstants.java | 9 +
.../iceberg/TestGravitinoIcebergCatalog.java | 159 ++++++++
.../iceberg/TestGravitinoIcebergCatalogOpen.java | 101 +++++
.../server/web/rest/TestCatalogOperations.java | 21 +
.../server/web/rest/TestFilesetOperations.java | 22 ++
.../server/web/rest/TestMetalakeOperations.java | 24 ++
.../server/web/rest/TestModelOperations.java | 22 ++
.../server/web/rest/TestPolicyOperations.java | 22 ++
.../server/web/rest/TestTableOperations.java | 22 ++
.../connector/iceberg/IcebergRestOAuthConfig.java | 15 +-
.../iceberg/TestIcebergRestOAuthConfig.java | 40 ++
.../testsets/jdbc-mysql/00008_alter_catalog.txt | 8 +-
.../gravitino/trino/connector/GravitinoConfig.java | 9 +-
.../trino/connector/TestGravitinoConfig.java | 5 +-
102 files changed, 5266 insertions(+), 424 deletions(-)
create mode 100644
catalogs/catalog-jdbc-doris/src/test/java/org/apache/gravitino/catalog/doris/operation/TestDorisDatabasePropertiesOperations.java
create mode 100644
catalogs/catalog-jdbc-postgresql/src/test/java/org/apache/gravitino/catalog/postgresql/converter/TestPostgreSqlColumnDefaultValueConverter.java
create mode 100644
core/src/main/java/org/apache/gravitino/utils/RenameUtils.java
create mode 100644
core/src/test/java/org/apache/gravitino/TestGravitinoEnvShutdown.java
copy
core/src/test/java/org/apache/gravitino/connector/{TestBaseCatalogInUse.java =>
TestBaseCatalogCredentialProviders.java} (50%)
create mode 100644
core/src/test/java/org/apache/gravitino/storage/relational/TestRenameConflicts.java
create mode 100644
core/src/test/java/org/apache/gravitino/utils/TestRenameUtils.java
create mode 100644
flink-connector/flink-common/src/test/java/org/apache/gravitino/flink/connector/iceberg/TestGravitinoIcebergCatalogOpen.java