Skip to content
Merged
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -236,7 +236,7 @@ public void createNamespace(Namespace namespace, Map<String, String> meta) {
!namespace.isEmpty(),
"Cannot create namespace with invalid name: %s", namespace);
Preconditions.checkArgument(isValidateNamespace(namespace),
"Cannot support multi part namespace in Hive MetaStore: %s", namespace);
"Cannot support multi part namespace in Hive Metastore: %s", namespace);

try {
clients.run(client -> {
Expand All @@ -251,12 +251,12 @@ public void createNamespace(Namespace namespace, Map<String, String> meta) {
namespace);

} catch (TException e) {
throw new RuntimeException("Failed to create namespace " + namespace + " in Hive MataStore", e);
throw new RuntimeException("Failed to create namespace " + namespace + " in Hive Metastore", e);

} catch (InterruptedException e) {
Thread.currentThread().interrupt();
throw new RuntimeException(
"Interrupted in call to createDatabase(name) " + namespace + " in Hive MataStore", e);
"Interrupted in call to createDatabase(name) " + namespace + " in Hive Metastore", e);
}
}

Expand All @@ -278,12 +278,12 @@ public List<Namespace> listNamespaces(Namespace namespace) {
return namespaces;

} catch (TException e) {
throw new RuntimeException("Failed to list all namespace: " + namespace + " in Hive MataStore", e);
throw new RuntimeException("Failed to list all namespace: " + namespace + " in Hive Metastore", e);

} catch (InterruptedException e) {
Thread.currentThread().interrupt();
throw new RuntimeException(
"Interrupted in call to getAllDatabases() " + namespace + " in Hive MataStore", e);
"Interrupted in call to getAllDatabases() " + namespace + " in Hive Metastore", e);
}
}

Expand Down Expand Up @@ -312,12 +312,12 @@ public boolean dropNamespace(Namespace namespace) {
return false;

} catch (TException e) {
throw new RuntimeException("Failed to drop namespace " + namespace + " in Hive MataStore", e);
throw new RuntimeException("Failed to drop namespace " + namespace + " in Hive Metastore", e);

} catch (InterruptedException e) {
Thread.currentThread().interrupt();
throw new RuntimeException(
"Interrupted in call to drop dropDatabase(name) " + namespace + " in Hive MataStore", e);
"Interrupted in call to drop dropDatabase(name) " + namespace + " in Hive Metastore", e);
}
}

Expand Down Expand Up @@ -363,11 +363,11 @@ private void alterHiveDataBase(Namespace namespace, Database database) {

} catch (TException e) {
throw new RuntimeException(
"Failed to list namespace under namespace: " + namespace + " in Hive MataStore", e);
"Failed to list namespace under namespace: " + namespace + " in Hive Metastore", e);

} catch (InterruptedException e) {
Thread.currentThread().interrupt();
throw new RuntimeException("Interrupted in call to getDatabase(name) " + namespace + " in Hive MataStore", e);
throw new RuntimeException("Interrupted in call to getDatabase(name) " + namespace + " in Hive Metastore", e);
}
}

Expand All @@ -387,12 +387,12 @@ public Map<String, String> loadNamespaceMetadata(Namespace namespace) {
throw new NoSuchNamespaceException(e, "Namespace does not exist: %s", namespace);

} catch (TException e) {
throw new RuntimeException("Failed to list namespace under namespace: " + namespace + " in Hive MataStore", e);
throw new RuntimeException("Failed to list namespace under namespace: " + namespace + " in Hive Metastore", e);

} catch (InterruptedException e) {
Thread.currentThread().interrupt();
throw new RuntimeException(
"Interrupted in call to getDatabase(name) " + namespace + " in Hive MataStore", e);
"Interrupted in call to getDatabase(name) " + namespace + " in Hive Metastore", e);
}
}

Expand Down