diff --git a/core/trino-main/src/main/java/io/trino/transaction/InMemoryTransactionManager.java b/core/trino-main/src/main/java/io/trino/transaction/InMemoryTransactionManager.java index 78af70f0a3eb..40cef048c6a4 100644 --- a/core/trino-main/src/main/java/io/trino/transaction/InMemoryTransactionManager.java +++ b/core/trino-main/src/main/java/io/trino/transaction/InMemoryTransactionManager.java @@ -189,14 +189,14 @@ public Map getCatalogs(TransactionId transactionId) @Override public Optional getCatalogName(TransactionId transactionId, String catalogName) { - return getTransactionMetadata(transactionId).getCalogName(catalogName); + return getTransactionMetadata(transactionId).getCatalogName(catalogName); } @Override public Optional getOptionalCatalogMetadata(TransactionId transactionId, String catalogName) { TransactionMetadata transactionMetadata = getTransactionMetadata(transactionId); - return transactionMetadata.getCalogName(catalogName) + return transactionMetadata.getCatalogName(catalogName) .map(transactionMetadata::getTransactionCatalogMetadata); } @@ -220,7 +220,7 @@ public CatalogMetadata getCatalogMetadataForWrite(TransactionId transactionId, S TransactionMetadata transactionMetadata = getTransactionMetadata(transactionId); // there is no need to ask for a connector specific id since the overlay connectors are read only - CatalogName catalog = transactionMetadata.getCalogName(catalogName) + CatalogName catalog = transactionMetadata.getCatalogName(catalogName) .orElseThrow(() -> new TrinoException(NOT_FOUND, "Catalog does not exist: " + catalogName)); return getCatalogMetadataForWrite(transactionId, catalog); @@ -389,7 +389,7 @@ private synchronized Map getCatalogs() return ImmutableMap.copyOf(catalogs); } - private synchronized Optional getCalogName(String catalogName) + private synchronized Optional getCatalogName(String catalogName) { Optional catalog = catalogByName.get(catalogName); if (catalog == null) {