This is an automated email from the ASF dual-hosted git repository.
yuqi4733 pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/gravitino.git
The following commit(s) were added to refs/heads/main by this push:
new 966f5207f [MINOR] fix: Fix some typos (#4274)
966f5207f is described below
commit 966f5207f81cb84e876b74115137a8d95c725b5e
Author: RickyMa <[email protected]>
AuthorDate: Fri Jul 26 10:37:33 2024 +0800
[MINOR] fix: Fix some typos (#4274)
### What changes were proposed in this pull request?
Fix some typos.
### Why are the changes needed?
Better code readability & maintainability.
### Does this PR introduce _any_ user-facing change?
No.
### How was this patch tested?
Existing UTs.
---
.../java/org/apache/gravitino/authorization/SecurableObjects.java | 4 ++--
bin/gravitino-iceberg-rest-server.sh | 2 +-
bin/gravitino.sh | 2 +-
.../hadoop/integration/test/HadoopUserAuthenticationIT.java | 4 ++--
.../catalog/doris/operation/TestDorisTableOperations.java | 2 +-
.../catalog/mysql/integration/test/AuditCatalogMysqlIT.java | 2 +-
.../main/java/org/apache/gravitino/client/GravitinoVersion.java | 4 ++--
clients/client-python/gravitino/constants/error.py | 4 ++--
clients/client-python/gravitino/exceptions/base.py | 6 +++---
clients/client-python/tests/integration/test_metalake.py | 6 +++---
clients/client-python/tests/integration/test_schema.py | 6 +++---
clients/client-python/tests/unittests/test_error_handler.py | 6 +++---
clients/client-python/tests/unittests/test_metalake.py | 4 ++--
.../java/org/apache/gravitino/filesystem/hadoop/TestGvfsBase.java | 2 +-
.../apache/gravitino/dto/authorization/SecurableObjectDTO.java | 2 +-
.../apache/gravitino/storage/relational/po/SecurableObjectPO.java | 2 +-
.../gravitino/storage/relational/service/FilesetMetaService.java | 2 +-
core/src/main/java/org/apache/gravitino/utils/Bytes.java | 2 +-
.../java/org/apache/gravitino/proto/TestEntityProtoSerDe.java | 2 +-
docs/gravitino-server-config.md | 2 +-
docs/manage-messaging-metadata-using-gravitino.md | 2 +-
docs/manage-metalake-using-gravitino.md | 2 +-
docs/manage-relational-metadata-using-gravitino.md | 2 +-
docs/trino-connector/catalog-hive.md | 2 +-
docs/trino-connector/catalog-iceberg.md | 2 +-
docs/trino-connector/trino-connector.md | 2 +-
.../gravitino/flink/connector/integration/test/FlinkCommonIT.java | 2 +-
.../gravitino/integration/test/util/CloseContainerExtension.java | 2 +-
.../apache/gravitino/integration/test/util/GravitinoITUtils.java | 2 +-
.../gravitino/integration/test/util/JdbcDriverDownloader.java | 8 ++++----
.../org/apache/gravitino/integration/test/util/ProcessData.java | 2 +-
.../apache/gravitino/integration/test/util/TestDatabaseName.java | 2 +-
.../gravitino/integration/test/authorization/ranger/RangerIT.java | 4 ++--
.../apache/gravitino/integration/test/trino/TrinoConnectorIT.java | 2 +-
.../gravitino/integration/test/web/ui/CatalogsPageTest.java | 2 +-
.../java/org/apache/gravitino/server/web/TestJettyServer.java | 2 +-
.../spark/connector/iceberg/GravitinoIcebergCatalog.java | 4 ++--
.../catalog/jdbc/postgresql/PostgreSQLConnectorAdapter.java | 2 +-
38 files changed, 56 insertions(+), 56 deletions(-)
diff --git
a/api/src/main/java/org/apache/gravitino/authorization/SecurableObjects.java
b/api/src/main/java/org/apache/gravitino/authorization/SecurableObjects.java
index 8378bb215..22e2b258b 100644
--- a/api/src/main/java/org/apache/gravitino/authorization/SecurableObjects.java
+++ b/api/src/main/java/org/apache/gravitino/authorization/SecurableObjects.java
@@ -161,7 +161,7 @@ public class SecurableObjects {
*
* @param fullName The full name of securable object.
* @param type The securable object type.
- * @param privileges The secureable object privileges.
+ * @param privileges The securable object privileges.
* @return The created {@link SecurableObject}
*/
public static SecurableObject parse(
@@ -176,7 +176,7 @@ public class SecurableObjects {
*
* @param type The securable object type.
* @param names The names of the securable object.
- * @param privileges The secureable object privileges.
+ * @param privileges The securable object privileges.
* @return The created {@link SecurableObject}
*/
static SecurableObject of(
diff --git a/bin/gravitino-iceberg-rest-server.sh
b/bin/gravitino-iceberg-rest-server.sh
index 91079cf8e..9236d5a50 100755
--- a/bin/gravitino-iceberg-rest-server.sh
+++ b/bin/gravitino-iceberg-rest-server.sh
@@ -176,7 +176,7 @@ if [ "$JVM_VERSION" -eq 17 ]; then
JAVA_OPTS+=" --add-opens java.security.jgss/sun.security.krb5=ALL-UNNAMED"
fi
-#JAVA_OPTS+=" -Djava.securit.krb5.conf=/etc/krb5.conf"
+#JAVA_OPTS+=" -Djava.security.krb5.conf=/etc/krb5.conf"
if [ -d "${GRAVITINO_HOME}/iceberg-rest-server/libs" ]; then
addJarInDir "${GRAVITINO_HOME}/iceberg-rest-server/libs"
diff --git a/bin/gravitino.sh b/bin/gravitino.sh
index 0ba536499..e29d05c03 100755
--- a/bin/gravitino.sh
+++ b/bin/gravitino.sh
@@ -176,7 +176,7 @@ if [ "$JVM_VERSION" -eq 17 ]; then
JAVA_OPTS+=" --add-opens java.security.jgss/sun.security.krb5=ALL-UNNAMED"
fi
-#JAVA_OPTS+=" -Djava.securit.krb5.conf=/etc/krb5.conf"
+#JAVA_OPTS+=" -Djava.security.krb5.conf=/etc/krb5.conf"
addJarInDir "${GRAVITINO_HOME}/libs"
diff --git
a/catalogs/catalog-hadoop/src/test/java/org/apache/gravitino/catalog/hadoop/integration/test/HadoopUserAuthenticationIT.java
b/catalogs/catalog-hadoop/src/test/java/org/apache/gravitino/catalog/hadoop/integration/test/HadoopUserAuthenticationIT.java
index 6c5fc1ae6..ba495ef6e 100644
---
a/catalogs/catalog-hadoop/src/test/java/org/apache/gravitino/catalog/hadoop/integration/test/HadoopUserAuthenticationIT.java
+++
b/catalogs/catalog-hadoop/src/test/java/org/apache/gravitino/catalog/hadoop/integration/test/HadoopUserAuthenticationIT.java
@@ -410,13 +410,13 @@ public class HadoopUserAuthenticationIT extends
AbstractIT {
// Create a catalog
Map<String, String> properties = Maps.newHashMap();
- String localtion = HDFS_URL + "/user/hadoop/" + catalogName;
+ String location = HDFS_URL + "/user/hadoop/" + catalogName;
properties.put(AUTH_TYPE_KEY, "kerberos");
properties.put(IMPERSONATION_ENABLE_KEY, "true");
properties.put(KEY_TAB_URI_KEY, TMP_DIR + HADOOP_CLIENT_KEYTAB);
properties.put(PRINCIPAL_KEY, HADOOP_CLIENT_PRINCIPAL);
- properties.put("location", localtion);
+ properties.put("location", location);
kerberosHiveContainer.executeInContainer(
"hadoop", "fs", "-mkdir", "-p", "/user/hadoop/" + catalogName);
diff --git
a/catalogs/catalog-jdbc-doris/src/test/java/org/apache/gravitino/catalog/doris/operation/TestDorisTableOperations.java
b/catalogs/catalog-jdbc-doris/src/test/java/org/apache/gravitino/catalog/doris/operation/TestDorisTableOperations.java
index 1ac9146af..62c763f3d 100644
---
a/catalogs/catalog-jdbc-doris/src/test/java/org/apache/gravitino/catalog/doris/operation/TestDorisTableOperations.java
+++
b/catalogs/catalog-jdbc-doris/src/test/java/org/apache/gravitino/catalog/doris/operation/TestDorisTableOperations.java
@@ -398,7 +398,7 @@ public class TestDorisTableOperations extends TestDoris {
@Test
public void testCreateNotSupportTypeTable() {
- String tableName = RandomNameUtils.genRandomName("unspport_type_table");
+ String tableName = RandomNameUtils.genRandomName("unsupported_type_table");
String tableComment = "test_comment";
List<JdbcColumn> columns = new ArrayList<>();
List<Type> notSupportType =
diff --git
a/catalogs/catalog-jdbc-mysql/src/test/java/org/apache/gravitino/catalog/mysql/integration/test/AuditCatalogMysqlIT.java
b/catalogs/catalog-jdbc-mysql/src/test/java/org/apache/gravitino/catalog/mysql/integration/test/AuditCatalogMysqlIT.java
index 8798ef37b..e5503b0f1 100644
---
a/catalogs/catalog-jdbc-mysql/src/test/java/org/apache/gravitino/catalog/mysql/integration/test/AuditCatalogMysqlIT.java
+++
b/catalogs/catalog-jdbc-mysql/src/test/java/org/apache/gravitino/catalog/mysql/integration/test/AuditCatalogMysqlIT.java
@@ -115,7 +115,7 @@ public class AuditCatalogMysqlIT extends AbstractIT {
@Test
public void testAuditTable() throws Exception {
String catalogName =
GravitinoITUtils.genRandomName("audit_mysql_table_catalog");
- String schemaName =
GravitinoITUtils.genRandomName("audit_mysql_table_schma");
+ String schemaName =
GravitinoITUtils.genRandomName("audit_mysql_table_schema");
String tableName = GravitinoITUtils.genRandomName("audit_mysql_table");
Catalog catalog = createCatalog(catalogName);
Map<String, String> properties = Maps.newHashMap();
diff --git
a/clients/client-java/src/main/java/org/apache/gravitino/client/GravitinoVersion.java
b/clients/client-java/src/main/java/org/apache/gravitino/client/GravitinoVersion.java
index c531bfecb..6e343bb3a 100644
---
a/clients/client-java/src/main/java/org/apache/gravitino/client/GravitinoVersion.java
+++
b/clients/client-java/src/main/java/org/apache/gravitino/client/GravitinoVersion.java
@@ -30,8 +30,8 @@ public class GravitinoVersion extends VersionDTO implements
Comparable {
private static final int VERSION_PART_NUMBER = 3;
@VisibleForTesting
- GravitinoVersion(String version, String compoileDate, String gitCommit) {
- super(version, compoileDate, gitCommit);
+ GravitinoVersion(String version, String compileDate, String gitCommit) {
+ super(version, compileDate, gitCommit);
}
GravitinoVersion(VersionDTO versionDTO) {
diff --git a/clients/client-python/gravitino/constants/error.py
b/clients/client-python/gravitino/constants/error.py
index 8f4bdbffb..ed2424200 100644
--- a/clients/client-python/gravitino/constants/error.py
+++ b/clients/client-python/gravitino/constants/error.py
@@ -21,7 +21,7 @@ from enum import IntEnum
from gravitino.exceptions.base import (
RESTException,
- IllegalArugmentException,
+ IllegalArgumentException,
NotFoundException,
InternalError,
AlreadyExistException,
@@ -60,7 +60,7 @@ class ErrorConstants(IntEnum):
EXCEPTION_MAPPING = {
RESTException: ErrorConstants.REST_ERROR_CODE,
- IllegalArugmentException: ErrorConstants.ILLEGAL_ARGUMENTS_CODE,
+ IllegalArgumentException: ErrorConstants.ILLEGAL_ARGUMENTS_CODE,
InternalError: ErrorConstants.INTERNAL_ERROR_CODE,
NotFoundException: ErrorConstants.NOT_FOUND_CODE,
AlreadyExistException: ErrorConstants.ALREADY_EXISTS_CODE,
diff --git a/clients/client-python/gravitino/exceptions/base.py
b/clients/client-python/gravitino/exceptions/base.py
index 96081f1ae..c9c46c575 100644
--- a/clients/client-python/gravitino/exceptions/base.py
+++ b/clients/client-python/gravitino/exceptions/base.py
@@ -32,18 +32,18 @@ class RESTException(RuntimeError):
super().__init__(message % args)
-class IllegalArugmentException(ValueError):
+class IllegalArgumentException(ValueError):
"""Base class for all exceptions thrown when arguments are invalid."""
def __init__(self, message, *args):
super().__init__(message % args)
-class IllegalNameIdentifierException(IllegalArugmentException):
+class IllegalNameIdentifierException(IllegalArgumentException):
"""An exception thrown when a name identifier is invalid."""
-class IllegalNamespaceException(IllegalArugmentException):
+class IllegalNamespaceException(IllegalArgumentException):
"""An exception thrown when a namespace is invalid."""
diff --git a/clients/client-python/tests/integration/test_metalake.py
b/clients/client-python/tests/integration/test_metalake.py
index fd8fe29ef..cd588578c 100644
--- a/clients/client-python/tests/integration/test_metalake.py
+++ b/clients/client-python/tests/integration/test_metalake.py
@@ -80,14 +80,14 @@ class TestMetalake(IntegrationTestEnv):
metalake_new_name = self.metalake_name + "_new"
metalake_new_comment = self.metalake_comment + "_new"
- metalake_propertie_new_value: str = "metalake_propertie_new_value1"
+ metalake_properties_new_value: str = "metalake_properties_new_value1"
changes = (
MetalakeChange.rename(metalake_new_name),
MetalakeChange.update_comment(metalake_new_comment),
MetalakeChange.remove_property(self.metalake_properties_key1),
MetalakeChange.set_property(
- self.metalake_properties_key2, metalake_propertie_new_value
+ self.metalake_properties_key2, metalake_properties_new_value
),
)
@@ -98,7 +98,7 @@ class TestMetalake(IntegrationTestEnv):
self.assertEqual(metalake.comment(), metalake_new_comment)
self.assertEqual(
metalake.properties().get(self.metalake_properties_key2),
- metalake_propertie_new_value,
+ metalake_properties_new_value,
)
self.assertTrue(self.metalake_properties_key1 not in
metalake.properties())
diff --git a/clients/client-python/tests/integration/test_schema.py
b/clients/client-python/tests/integration/test_schema.py
index 80fbff6fe..eb250f64a 100644
--- a/clients/client-python/tests/integration/test_schema.py
+++ b/clients/client-python/tests/integration/test_schema.py
@@ -160,18 +160,18 @@ class TestSchema(IntegrationTestEnv):
def test_alter_schema(self):
self.create_schema()
- schema_propertie_new_value = self.schema_properties_value2 + "_new"
+ schema_properties_new_value = self.schema_properties_value2 + "_new"
changes = (
SchemaChange.remove_property(self.schema_properties_key1),
SchemaChange.set_property(
- self.schema_properties_key2, schema_propertie_new_value
+ self.schema_properties_key2, schema_properties_new_value
),
)
catalog = self.gravitino_client.load_catalog(name=self.catalog_name)
schema_new = catalog.as_schemas().alter_schema(self.schema_name,
*changes)
self.assertEqual(
schema_new.properties().get(self.schema_properties_key2),
- schema_propertie_new_value,
+ schema_properties_new_value,
)
self.assertTrue(self.schema_properties_key1 not in
schema_new.properties())
diff --git a/clients/client-python/tests/unittests/test_error_handler.py
b/clients/client-python/tests/unittests/test_error_handler.py
index 565c08151..2600beac9 100644
--- a/clients/client-python/tests/unittests/test_error_handler.py
+++ b/clients/client-python/tests/unittests/test_error_handler.py
@@ -26,7 +26,7 @@ from gravitino.exceptions.base import (
InternalError,
RESTException,
NotFoundException,
- IllegalArugmentException,
+ IllegalArgumentException,
AlreadyExistException,
NotEmptyException,
UnsupportedOperationException,
@@ -45,10 +45,10 @@ class TestErrorHandler(unittest.TestCase):
ErrorResponse.generate_error_response(RESTException, "mock
error")
)
- with self.assertRaises(IllegalArugmentException):
+ with self.assertRaises(IllegalArgumentException):
REST_ERROR_HANDLER.handle(
ErrorResponse.generate_error_response(
- IllegalArugmentException, "mock error"
+ IllegalArgumentException, "mock error"
)
)
diff --git a/clients/client-python/tests/unittests/test_metalake.py
b/clients/client-python/tests/unittests/test_metalake.py
index b4ca90c05..b473618ad 100644
--- a/clients/client-python/tests/unittests/test_metalake.py
+++ b/clients/client-python/tests/unittests/test_metalake.py
@@ -39,8 +39,8 @@ class TestMetalake(unittest.TestCase):
def test_from_error_json_metalake_response(self):
str_json = (
- b'{"code":0, "undefine-key1":"undefine-value1", '
- b'"metalake":{"undefine-key2":1,
"name":"example_name18","comment":"This is a sample comment",'
+ b'{"code":0, "undefined-key1":"undefined-value1", '
+ b'"metalake":{"undefined-key2":1,
"name":"example_name18","comment":"This is a sample comment",'
b'"properties":{"key1":"value1","key2":"value2"},'
b'"audit":{"creator":"anonymous","createTime":"2024-04-05T10:10:35.218Z"}}}'
)
diff --git
a/clients/filesystem-hadoop3/src/test/java/org/apache/gravitino/filesystem/hadoop/TestGvfsBase.java
b/clients/filesystem-hadoop3/src/test/java/org/apache/gravitino/filesystem/hadoop/TestGvfsBase.java
index 13b365a25..448d42f81 100644
---
a/clients/filesystem-hadoop3/src/test/java/org/apache/gravitino/filesystem/hadoop/TestGvfsBase.java
+++
b/clients/filesystem-hadoop3/src/test/java/org/apache/gravitino/filesystem/hadoop/TestGvfsBase.java
@@ -159,7 +159,7 @@ public class TestGvfsBase extends GravitinoMockServerBase {
assertNotEquals(externalFs, gravitinoFileSystem);
}
- // test proxyed local fs, should not get the same fs
+ // test proxied local fs, should not get the same fs
FileSystemTestUtils.mkdirs(managedFilesetPath, gravitinoFileSystem);
FileSystem proxyLocalFs =
Objects.requireNonNull(
diff --git
a/common/src/main/java/org/apache/gravitino/dto/authorization/SecurableObjectDTO.java
b/common/src/main/java/org/apache/gravitino/dto/authorization/SecurableObjectDTO.java
index b10a3e63f..8a10d93df 100644
---
a/common/src/main/java/org/apache/gravitino/dto/authorization/SecurableObjectDTO.java
+++
b/common/src/main/java/org/apache/gravitino/dto/authorization/SecurableObjectDTO.java
@@ -49,7 +49,7 @@ public class SecurableObjectDTO implements SecurableObject {
/**
* Creates a new instance of SecurableObject DTO.
*
- * @param privileges The privileges of the ScecurableObject DTO.
+ * @param privileges The privileges of the SecurableObject DTO.
* @param fullName The name of the SecurableObject DTO.
* @param type The type of the securable object.
*/
diff --git
a/core/src/main/java/org/apache/gravitino/storage/relational/po/SecurableObjectPO.java
b/core/src/main/java/org/apache/gravitino/storage/relational/po/SecurableObjectPO.java
index d9703cdd6..f58364285 100644
---
a/core/src/main/java/org/apache/gravitino/storage/relational/po/SecurableObjectPO.java
+++
b/core/src/main/java/org/apache/gravitino/storage/relational/po/SecurableObjectPO.java
@@ -149,7 +149,7 @@ public class SecurableObjectPO {
Preconditions.checkArgument(
securableObjectPO.privilegeNames != null, "Privilege names are
required");
Preconditions.checkArgument(
- securableObjectPO.privilegeConditions != null, "Priviege conditions
are required");
+ securableObjectPO.privilegeConditions != null, "Privilege conditions
are required");
Preconditions.checkArgument(
securableObjectPO.currentVersion != null, "Current version is
required");
Preconditions.checkArgument(
diff --git
a/core/src/main/java/org/apache/gravitino/storage/relational/service/FilesetMetaService.java
b/core/src/main/java/org/apache/gravitino/storage/relational/service/FilesetMetaService.java
index 18c997d9a..2dca16daa 100644
---
a/core/src/main/java/org/apache/gravitino/storage/relational/service/FilesetMetaService.java
+++
b/core/src/main/java/org/apache/gravitino/storage/relational/service/FilesetMetaService.java
@@ -71,7 +71,7 @@ public class FilesetMetaService {
return filesetPO;
}
- // Filset may be deleted, so the FilesetPO may be null.
+ // Fileset may be deleted, so the FilesetPO may be null.
public FilesetPO getFilesetPOById(Long filesetId) {
FilesetPO filesetPO =
SessionUtils.getWithoutCommit(
diff --git a/core/src/main/java/org/apache/gravitino/utils/Bytes.java
b/core/src/main/java/org/apache/gravitino/utils/Bytes.java
index b83710a70..1957c16b8 100644
--- a/core/src/main/java/org/apache/gravitino/utils/Bytes.java
+++ b/core/src/main/java/org/apache/gravitino/utils/Bytes.java
@@ -186,7 +186,7 @@ public class Bytes implements Comparable<byte[]> {
}
}
- /** A byte array comparator based on lexicograpic ordering. */
+ /** A byte array comparator based on lexicographic ordering. */
public static final ByteArrayComparator BYTES_LEXICO_COMPARATOR =
new LexicographicByteArrayComparator();
diff --git
a/core/src/test/java/org/apache/gravitino/proto/TestEntityProtoSerDe.java
b/core/src/test/java/org/apache/gravitino/proto/TestEntityProtoSerDe.java
index 1db0a1765..1d4bfaa17 100644
--- a/core/src/test/java/org/apache/gravitino/proto/TestEntityProtoSerDe.java
+++ b/core/src/test/java/org/apache/gravitino/proto/TestEntityProtoSerDe.java
@@ -394,7 +394,7 @@ public class TestEntityProtoSerDe {
Namespace.of("metalake", Entity.SYSTEM_CATALOG_RESERVED_NAME,
Entity.ROLE_SCHEMA_NAME);
Long roleId = 1L;
String roleName = "testRole";
- String anotherCatalogName = "anotheCatalog";
+ String anotherCatalogName = "anotherCatalog";
SecurableObject securableObject =
SecurableObjects.ofCatalog(
catalogName,
diff --git a/docs/gravitino-server-config.md b/docs/gravitino-server-config.md
index cc815f9ee..6a8e96b8f 100644
--- a/docs/gravitino-server-config.md
+++ b/docs/gravitino-server-config.md
@@ -165,7 +165,7 @@ Below is a list of catalog properties that will be used by
all Gravitino catalog
|---------------------|------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|---------------|----------|---------------|
| `package` | The path of the catalog package, Gravitino leverages
this path to load the related catalog libs and configurations. The package
should consist two folders, `conf` (for catalog related configurations) and
`libs` (for catalog related dependencies/jars) | (none) | No |
0.5.0 |
| `cloud.name` | The property to specify the cloud that the catalog is
running on. The valid values are `aws`, `azure`, `gcp`, `on_premise` and
`other`.
| (none) | No | 0.6.0
|
-| `cloud.region-code` | The property to specify the region code of the cloud
that the caatlog is running on.
| (none) | No | 0.6.0
|
+| `cloud.region-code` | The property to specify the region code of the cloud
that the catalog is running on.
| (none) | No | 0.6.0
|
The following table lists the catalog specific properties and their default
paths:
diff --git a/docs/manage-messaging-metadata-using-gravitino.md
b/docs/manage-messaging-metadata-using-gravitino.md
index 0b59f7b1d..9fc5d6adb 100644
--- a/docs/manage-messaging-metadata-using-gravitino.md
+++ b/docs/manage-messaging-metadata-using-gravitino.md
@@ -55,7 +55,7 @@ GravitinoClient gravitinoClient = GravitinoClient
.build();
Map<String, String> properties = ImmutableMap.<String, String>builder()
- // You should repalce the following with your own Kafka bootstrap servers
that Gravitino can connect to.
+ // You should replace the following with your own Kafka bootstrap servers
that Gravitino can connect to.
.put("bootstrap.servers", "localhost:9092")
.build();
diff --git a/docs/manage-metalake-using-gravitino.md
b/docs/manage-metalake-using-gravitino.md
index 6b4f9ee8e..bab226e44 100644
--- a/docs/manage-metalake-using-gravitino.md
+++ b/docs/manage-metalake-using-gravitino.md
@@ -138,7 +138,7 @@ changes = (
MetalakeChange.rename("metalake_new_name"),
MetalakeChange.update_comment("metalake_new_comment"),
MetalakeChange.remove_property("metalake_properties_key1"),
- MetalakeChange.set_property("metalake_properties_key2",
"metalake_propertie_new_value"),
+ MetalakeChange.set_property("metalake_properties_key2",
"metalake_properties_new_value"),
)
metalake = gravitino_admin_client.alter_metalake("metalake_name", *changes)
diff --git a/docs/manage-relational-metadata-using-gravitino.md
b/docs/manage-relational-metadata-using-gravitino.md
index a0e80e5f0..7eab5b4b7 100644
--- a/docs/manage-relational-metadata-using-gravitino.md
+++ b/docs/manage-relational-metadata-using-gravitino.md
@@ -403,7 +403,7 @@ catalog: Catalog =
gravitino_client.load_catalog(name="hive_catalog")
changes = (
SchemaChange.remove_property("schema_properties_key1"),
- SchemaChange.set_property("schema_properties_key2",
"schema_propertie_new_value"),
+ SchemaChange.set_property("schema_properties_key2",
"schema_properties_new_value"),
)
schema_new: Schema = catalog.as_schemas().alter_schema("schema",
*changes)
diff --git a/docs/trino-connector/catalog-hive.md
b/docs/trino-connector/catalog-hive.md
index 4d5cddba1..ba1332f4e 100644
--- a/docs/trino-connector/catalog-hive.md
+++ b/docs/trino-connector/catalog-hive.md
@@ -111,7 +111,7 @@ Reserved properties: A reserved property is one can't be
set by users but can be
Users can use the following example to create a table with properties:
```sql
-CREATE TABLE catalog.dbname.tabname
+CREATE TABLE catalog.dbname.tablename
(
name varchar,
salary int
diff --git a/docs/trino-connector/catalog-iceberg.md
b/docs/trino-connector/catalog-iceberg.md
index d81767e6d..19351412b 100644
--- a/docs/trino-connector/catalog-iceberg.md
+++ b/docs/trino-connector/catalog-iceberg.md
@@ -71,7 +71,7 @@ Iceberg schema does not support properties.
Users can use the following example to create a table with properties:
```sql
-CREATE TABLE "metalake.catalog".dbname.tabname
+CREATE TABLE "metalake.catalog".dbname.tablename
(
name varchar,
salary int
diff --git a/docs/trino-connector/trino-connector.md
b/docs/trino-connector/trino-connector.md
index bb4e252a4..f1167fe9a 100644
--- a/docs/trino-connector/trino-connector.md
+++ b/docs/trino-connector/trino-connector.md
@@ -26,7 +26,7 @@ By default, the loading of Gravitino's catalogs into Trino
follows the naming co
Usage in queries is as follows:
```text
-SELECT * from catalog.dbname.tabname
+SELECT * from catalog.dbname.tablename
```
diff --git
a/flink-connector/src/test/java/org/apache/gravitino/flink/connector/integration/test/FlinkCommonIT.java
b/flink-connector/src/test/java/org/apache/gravitino/flink/connector/integration/test/FlinkCommonIT.java
index 46b1d1d23..2d022b4a8 100644
---
a/flink-connector/src/test/java/org/apache/gravitino/flink/connector/integration/test/FlinkCommonIT.java
+++
b/flink-connector/src/test/java/org/apache/gravitino/flink/connector/integration/test/FlinkCommonIT.java
@@ -343,7 +343,7 @@ public abstract class FlinkCommonIT extends FlinkEnvIT {
@Test
public void testRenameColumn() {
- String databaseName = "test_renam_column_db";
+ String databaseName = "test_rename_column_db";
String tableName = "test_rename_column";
doWithSchema(
currentCatalog(),
diff --git
a/integration-test-common/src/test/java/org/apache/gravitino/integration/test/util/CloseContainerExtension.java
b/integration-test-common/src/test/java/org/apache/gravitino/integration/test/util/CloseContainerExtension.java
index 1ee9a8fe0..f3b3a5b5a 100644
---
a/integration-test-common/src/test/java/org/apache/gravitino/integration/test/util/CloseContainerExtension.java
+++
b/integration-test-common/src/test/java/org/apache/gravitino/integration/test/util/CloseContainerExtension.java
@@ -25,7 +25,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
- * This is an extension for juint 5, which aims to perform certain operations
(such as resource
+ * This is an extension for JUnit 5, which aims to perform certain operations
(such as resource
* recycling, etc.) after all test executions are completed (regardless of
success or failure). You
* can Refer to {@link AbstractIT} for more information.
*/
diff --git
a/integration-test-common/src/test/java/org/apache/gravitino/integration/test/util/GravitinoITUtils.java
b/integration-test-common/src/test/java/org/apache/gravitino/integration/test/util/GravitinoITUtils.java
index 476ea5dfb..4ed7fbf29 100644
---
a/integration-test-common/src/test/java/org/apache/gravitino/integration/test/util/GravitinoITUtils.java
+++
b/integration-test-common/src/test/java/org/apache/gravitino/integration/test/util/GravitinoITUtils.java
@@ -47,7 +47,7 @@ public class GravitinoITUtils {
FileUtils.readFileToString(new File(gravitinoStartShell),
StandardCharsets.UTF_8);
content =
content.replace(
- "#JAVA_OPTS+=\" -Djava.securit.krb5.conf=/etc/krb5.conf\"",
+ "#JAVA_OPTS+=\" -Djava.security.krb5.conf=/etc/krb5.conf\"",
String.format("JAVA_OPTS+=\" -Djava.security.krb5.conf=%s\"",
krb5Path));
File tmp = new File(modifiedGravitinoStartShell);
FileUtils.write(tmp, content, StandardCharsets.UTF_8);
diff --git
a/integration-test-common/src/test/java/org/apache/gravitino/integration/test/util/JdbcDriverDownloader.java
b/integration-test-common/src/test/java/org/apache/gravitino/integration/test/util/JdbcDriverDownloader.java
index 40087354a..f53417248 100644
---
a/integration-test-common/src/test/java/org/apache/gravitino/integration/test/util/JdbcDriverDownloader.java
+++
b/integration-test-common/src/test/java/org/apache/gravitino/integration/test/util/JdbcDriverDownloader.java
@@ -34,12 +34,12 @@ public class JdbcDriverDownloader {
public static final Logger LOG =
LoggerFactory.getLogger(JdbcDriverDownloader.class);
- public static void downloadJdbcDriver(String jdbcDriverUrl, String...
destinationDirectorys)
+ public static void downloadJdbcDriver(String jdbcDriverUrl, String...
destinationDirectories)
throws IOException {
URL url = new URL(jdbcDriverUrl);
URLConnection connection = url.openConnection();
String fileName = getFileName(url);
- String destinationDirectory = destinationDirectorys[0];
+ String destinationDirectory = destinationDirectories[0];
Path destinationPath = Paths.get(destinationDirectory, fileName);
File file = new File(destinationPath.toString());
if (!file.exists()) {
@@ -55,8 +55,8 @@ public class JdbcDriverDownloader {
LOG.info("Download jdbc-driver:{} success. path:{}", fileName,
destinationPath);
}
}
- for (int i = 1; i < destinationDirectorys.length; i++) {
- Path targetPath = Paths.get(destinationDirectorys[i], fileName);
+ for (int i = 1; i < destinationDirectories.length; i++) {
+ Path targetPath = Paths.get(destinationDirectories[i], fileName);
Files.copy(destinationPath, targetPath,
java.nio.file.StandardCopyOption.REPLACE_EXISTING);
}
}
diff --git
a/integration-test-common/src/test/java/org/apache/gravitino/integration/test/util/ProcessData.java
b/integration-test-common/src/test/java/org/apache/gravitino/integration/test/util/ProcessData.java
index a0215e1c5..cae25316d 100644
---
a/integration-test-common/src/test/java/org/apache/gravitino/integration/test/util/ProcessData.java
+++
b/integration-test-common/src/test/java/org/apache/gravitino/integration/test/util/ProcessData.java
@@ -280,7 +280,7 @@ public class ProcessData {
try {
if ((System.currentTimeMillis() > unconditionalExitTime)) {
LOG.error(
- "!Unconditional exit occured!\nsome process hag up for more
than "
+ "!Unconditional exit occurred!\nsome process hag up for more
than "
+ unconditionalExitDelayMinutes
+ " minutes.");
}
diff --git
a/integration-test-common/src/test/java/org/apache/gravitino/integration/test/util/TestDatabaseName.java
b/integration-test-common/src/test/java/org/apache/gravitino/integration/test/util/TestDatabaseName.java
index 3e4057131..98fb959ae 100644
---
a/integration-test-common/src/test/java/org/apache/gravitino/integration/test/util/TestDatabaseName.java
+++
b/integration-test-common/src/test/java/org/apache/gravitino/integration/test/util/TestDatabaseName.java
@@ -52,7 +52,7 @@ public enum TestDatabaseName {
/** Represents the MySQL database for MysqlAbstractIT and its subclasses. */
MYSQL_MYSQL_ABSTRACT_IT,
- /** Represents the MySQL database for AudtCatalogMysqlIT. */
+ /** Represents the MySQL database for AuditCatalogMysqlIT. */
MYSQL_AUDIT_CATALOG_MYSQL_IT,
/** Represents the MySQL database used for testing the catalog integration
with MySQL. */
diff --git
a/integration-test/src/test/java/org/apache/gravitino/integration/test/authorization/ranger/RangerIT.java
b/integration-test/src/test/java/org/apache/gravitino/integration/test/authorization/ranger/RangerIT.java
index 8b560ba2d..90cc1b14f 100644
---
a/integration-test/src/test/java/org/apache/gravitino/integration/test/authorization/ranger/RangerIT.java
+++
b/integration-test/src/test/java/org/apache/gravitino/integration/test/authorization/ranger/RangerIT.java
@@ -70,13 +70,13 @@ public class RangerIT {
}
}
- public void createRangerTrinoRepository(String tirnoIp) {
+ public void createRangerTrinoRepository(String trinoIp) {
String usernameKey = "username";
String usernameVal = "admin";
String jdbcKey = "jdbc.driverClassName";
String jdbcVal = "io.trino.jdbc.TrinoDriver";
String jdbcUrlKey = "jdbc.url";
- String jdbcUrlVal = String.format("http:hive2://%s:%d", tirnoIp,
TrinoContainer.TRINO_PORT);
+ String jdbcUrlVal = String.format("http:hive2://%s:%d", trinoIp,
TrinoContainer.TRINO_PORT);
RangerService service = new RangerService();
service.setType(RANGER_TRINO_TYPE);
diff --git
a/integration-test/src/test/java/org/apache/gravitino/integration/test/trino/TrinoConnectorIT.java
b/integration-test/src/test/java/org/apache/gravitino/integration/test/trino/TrinoConnectorIT.java
index f5804e69b..116f1943f 100644
---
a/integration-test/src/test/java/org/apache/gravitino/integration/test/trino/TrinoConnectorIT.java
+++
b/integration-test/src/test/java/org/apache/gravitino/integration/test/trino/TrinoConnectorIT.java
@@ -114,7 +114,7 @@ public class TrinoConnectorIT extends AbstractIT {
metalakeName);
Assertions.assertTrue(
containerSuite.getTrinoContainer().checkSyncCatalogFromGravitino(5,
catalogName),
- "Can not synchronize calatogs from gravitino");
+ "Can not synchronize catalogs from gravitino");
createSchema();
}
diff --git
a/integration-test/src/test/java/org/apache/gravitino/integration/test/web/ui/CatalogsPageTest.java
b/integration-test/src/test/java/org/apache/gravitino/integration/test/web/ui/CatalogsPageTest.java
index 8554f822d..976165951 100644
---
a/integration-test/src/test/java/org/apache/gravitino/integration/test/web/ui/CatalogsPageTest.java
+++
b/integration-test/src/test/java/org/apache/gravitino/integration/test/web/ui/CatalogsPageTest.java
@@ -581,7 +581,7 @@ public class CatalogsPageTest extends AbstractWebIT {
@Test
@Order(19)
- public void testOtherRelationaCatalogTreeNode() throws InterruptedException {
+ public void testOtherRelationalCatalogTreeNode() throws InterruptedException
{
String icebergNode =
String.format(
"{{%s}}{{%s}}{{%s}}", METALAKE_NAME, ICEBERG_CATALOG_NAME,
CATALOG_TYPE_RELATIONAL);
diff --git
a/server-common/src/test/java/org/apache/gravitino/server/web/TestJettyServer.java
b/server-common/src/test/java/org/apache/gravitino/server/web/TestJettyServer.java
index 963239b58..3ff3cfc2c 100644
---
a/server-common/src/test/java/org/apache/gravitino/server/web/TestJettyServer.java
+++
b/server-common/src/test/java/org/apache/gravitino/server/web/TestJettyServer.java
@@ -54,7 +54,7 @@ public class TestJettyServer {
JettyServerConfig serverConfig = JettyServerConfig.fromConfig(config);
jettyServer.initialize(serverConfig, "test", false);
- // TODO might be nice to have an isInitalised method or similar?
+ // TODO might be nice to have an isInitialised method or similar?
}
@Test
diff --git
a/spark-connector/spark-common/src/main/java/org/apache/gravitino/spark/connector/iceberg/GravitinoIcebergCatalog.java
b/spark-connector/spark-common/src/main/java/org/apache/gravitino/spark/connector/iceberg/GravitinoIcebergCatalog.java
index 0c67fb082..ceb0d7b08 100644
---
a/spark-connector/spark-common/src/main/java/org/apache/gravitino/spark/connector/iceberg/GravitinoIcebergCatalog.java
+++
b/spark-connector/spark-common/src/main/java/org/apache/gravitino/spark/connector/iceberg/GravitinoIcebergCatalog.java
@@ -108,8 +108,8 @@ public class GravitinoIcebergCatalog extends BaseCatalog
}
/**
- * Proceduers will validate the equality of the catalog registered to Spark
catalogManager and the
- * catalog passed to `ProcedureBuilder` which invokes loadProceduer(). To
meet the requirement ,
+ * Procedures will validate the equality of the catalog registered to Spark
catalogManager and the
+ * catalog passed to `ProcedureBuilder` which invokes loadProcedure(). To
meet the requirement ,
* override the method to pass `GravitinoIcebergCatalog` to the
`ProcedureBuilder` instead of the
* internal spark catalog.
*/
diff --git
a/trino-connector/src/main/java/org/apache/gravitino/trino/connector/catalog/jdbc/postgresql/PostgreSQLConnectorAdapter.java
b/trino-connector/src/main/java/org/apache/gravitino/trino/connector/catalog/jdbc/postgresql/PostgreSQLConnectorAdapter.java
index d088ea445..938ca69af 100644
---
a/trino-connector/src/main/java/org/apache/gravitino/trino/connector/catalog/jdbc/postgresql/PostgreSQLConnectorAdapter.java
+++
b/trino-connector/src/main/java/org/apache/gravitino/trino/connector/catalog/jdbc/postgresql/PostgreSQLConnectorAdapter.java
@@ -29,7 +29,7 @@ import
org.apache.gravitino.trino.connector.catalog.jdbc.JDBCCatalogPropertyConv
import org.apache.gravitino.trino.connector.metadata.GravitinoCatalog;
/**
- * Transforming PostgreSQL connector configuration and components into Apche
Gravitino connector.
+ * Transforming PostgreSQL connector configuration and components into Apache
Gravitino connector.
*/
public class PostgreSQLConnectorAdapter implements CatalogConnectorAdapter {
private final PropertyConverter catalogConverter;
