This is an automated email from the ASF dual-hosted git repository.
jshao pushed a change to branch
dependabot/npm_and_yarn/web/web/iconify/tools-4.1.2
in repository https://gitbox.apache.org/repos/asf/gravitino.git
from fd27de80f4 build(deps-dev): bump @iconify/tools from 4.1.1 to 4.1.2 in
/web/web
add edf401530f [MINOR] docs: add Iceberg REST server URI in document
(#6705)
add 3ba81470bc [#6075] improvement(core): Add event listener support for
Model system (#6703)
add e6de52ad01 [#6233] feat(flink): flink jdbc catalog (#6543)
add c1128d4555 [MINOR] Update the asf.yaml to add new collaborators (#6707)
add cc1aa1e284 [#5289][Improvement] CatalogMysqlDriverIT miss driver url
(#6671)
add c54b9bd8eb [#6682] fix(authz): Remove `privilege_names` and
`privilege_conditions` check when delete securable objects of a role. (#6690)
add fd4a9691ec build(deps-dev): bump autoprefixer from 10.4.20 to 10.4.21
in /web/web (#6702)
add 6325defd2e Merge branch 'main' into
dependabot/npm_and_yarn/web/web/iconify/tools-4.1.2
No new revisions were added by this update.
Summary of changes:
.asf.yaml | 5 +-
.../jdbc/operation/JdbcTableOperations.java | 5 +-
.../integration/test/CatalogMysqlDriverIT.java | 2 +
.../mysql/integration/test/CatalogMysqlIT.java | 21 ++-
.../test/authorization/AccessControlIT.java | 43 +++++
.../java/org/apache/gravitino/GravitinoEnv.java | 5 +-
.../base/SecurableObjectBaseSQLProvider.java | 4 +-
docs/iceberg-rest-service.md | 2 +-
flink-connector/flink/build.gradle.kts | 2 +
.../flink/connector/PropertiesConverter.java | 15 +-
...erter.java => UnsupportPartitionConverter.java} | 26 ++-
.../flink/connector/catalog/BaseCatalog.java | 9 +-
.../flink/connector/hive/GravitinoHiveCatalog.java | 4 +-
.../hive/GravitinoHiveCatalogFactory.java | 1 +
.../connector/hive/HivePropertiesConverter.java | 8 +-
.../connector/iceberg/GravitinoIcebergCatalog.java | 12 +-
.../GravitinoJdbcCatalog.java} | 48 ++---
.../GravitinoJdbcCatalogFactory.java} | 53 +++---
.../GravitinoJdbcCatalogFactoryOptions.java} | 16 +-
.../connector/jdbc/JdbcPropertiesConstants.java | 55 ++++++
.../connector/jdbc/JdbcPropertiesConverter.java | 101 ++++++++++
.../mysql/GravitinoMysqlJdbcCatalogFactory.java | 28 ++-
.../jdbc/mysql/MysqlPropertiesConverter.java | 22 ++-
.../GravitinoPostgresJdbcCatalogFactory.java | 33 ++--
.../postgresql/PostgresqlPropertiesConverter.java | 22 ++-
.../connector/paimon/GravitinoPaimonCatalog.java | 7 +-
.../org.apache.flink.table.factories.Factory | 2 +
.../connector/integration/test/FlinkCommonIT.java | 52 ++++-
.../connector/integration/test/FlinkEnvIT.java | 8 +-
.../integration/test/hive/FlinkHiveCatalogIT.java | 1 -
.../test/iceberg/FlinkIcebergCatalogIT.java | 1 -
.../test/jdbc/FlinkJdbcMysqlCatalogIT.java | 210 +++++++++++++++++++++
.../test/paimon/FlinkPaimonCatalogIT.java | 2 +-
.../integration/test/utils/TestUtils.java | 14 --
.../AbstractJdbcPropertiesConverterTestSuite.java | 156 +++++++++++++++
.../jdbc/TestMysqlPropertiesConverter.java | 13 +-
.../jdbc/TestPostgresqlPropertiesConverter.java | 13 +-
gradle/libs.versions.toml | 2 +
.../gravitino/integration/test/util/BaseIT.java | 2 +-
web/web/package.json | 2 +-
web/web/pnpm-lock.yaml | 27 +--
41 files changed, 835 insertions(+), 219 deletions(-)
copy
flink-connector/flink/src/main/java/org/apache/gravitino/flink/connector/{DefaultPartitionConverter.java
=> UnsupportPartitionConverter.java} (59%)
copy
flink-connector/flink/src/main/java/org/apache/gravitino/flink/connector/{hive/GravitinoHiveCatalog.java
=> jdbc/GravitinoJdbcCatalog.java} (57%)
copy
flink-connector/flink/src/main/java/org/apache/gravitino/flink/connector/{paimon/GravitinoPaimonCatalogFactory.java
=> jdbc/GravitinoJdbcCatalogFactory.java} (61%)
copy
flink-connector/flink/src/main/java/org/apache/gravitino/flink/connector/{iceberg/GravitinoIcebergCatalogFactoryOptions.java
=> jdbc/GravitinoJdbcCatalogFactoryOptions.java} (68%)
create mode 100644
flink-connector/flink/src/main/java/org/apache/gravitino/flink/connector/jdbc/JdbcPropertiesConstants.java
create mode 100644
flink-connector/flink/src/main/java/org/apache/gravitino/flink/connector/jdbc/JdbcPropertiesConverter.java
copy
iceberg/iceberg-common/src/test/java/org/apache/gravitino/iceberg/common/utils/CustomCatalogForTest.java
=>
flink-connector/flink/src/main/java/org/apache/gravitino/flink/connector/jdbc/mysql/GravitinoMysqlJdbcCatalogFactory.java
(57%)
copy
spark-connector/spark-common/src/main/java/org/apache/gravitino/spark/connector/plugin/GravitinoSparkPlugin.java
=>
flink-connector/flink/src/main/java/org/apache/gravitino/flink/connector/jdbc/mysql/MysqlPropertiesConverter.java
(58%)
copy core/src/test/java/org/apache/gravitino/audit/DummyAuditWriter.java =>
flink-connector/flink/src/main/java/org/apache/gravitino/flink/connector/jdbc/postgresql/GravitinoPostgresJdbcCatalogFactory.java
(56%)
copy
spark-connector/v3.4/spark/src/main/java/org/apache/gravitino/spark/connector/jdbc/GravitinoJdbcCatalogSpark34.java
=>
flink-connector/flink/src/main/java/org/apache/gravitino/flink/connector/jdbc/postgresql/PostgresqlPropertiesConverter.java
(57%)
create mode 100644
flink-connector/flink/src/test/java/org/apache/gravitino/flink/connector/integration/test/jdbc/FlinkJdbcMysqlCatalogIT.java
create mode 100644
flink-connector/flink/src/test/java/org/apache/gravitino/flink/connector/jdbc/AbstractJdbcPropertiesConverterTestSuite.java
copy
catalogs/catalog-model/src/main/java/org/apache/gravitino/catalog/model/ModelPropertiesMetadata.java
=>
flink-connector/flink/src/test/java/org/apache/gravitino/flink/connector/jdbc/TestMysqlPropertiesConverter.java
(70%)
copy
catalogs/catalog-kafka/src/main/java/org/apache/gravitino/catalog/kafka/KafkaSchemaPropertiesMetadata.java
=>
flink-connector/flink/src/test/java/org/apache/gravitino/flink/connector/jdbc/TestPostgresqlPropertiesConverter.java
(69%)