diff --git a/xtable-api/src/main/java/org/apache/xtable/spi/sync/CatalogSync.java b/xtable-api/src/main/java/org/apache/xtable/spi/sync/CatalogSync.java index c1bcf1a68..df25d0d31 100644 --- a/xtable-api/src/main/java/org/apache/xtable/spi/sync/CatalogSync.java +++ b/xtable-api/src/main/java/org/apache/xtable/spi/sync/CatalogSync.java @@ -67,7 +67,7 @@ private CatalogSyncStatus getCatalogSyncStatus( if (!doesDatabaseExists) { catalogSyncOperation.createDatabase(tableIdentifier.getDatabaseName()); } - Object catalogTable = catalogSyncOperation.getTable(tableIdentifier); + TABLE catalogTable = catalogSyncOperation.getTable(tableIdentifier); String storageDescriptorLocation = catalogSyncOperation.getStorageDescriptorLocation(catalogTable); if (catalogTable == null) {