diff --git a/kernel/kernel-defaults/src/main/java/io/delta/kernel/defaults/engine/DefaultCommitCoordinatorClientHandler.java b/kernel/kernel-defaults/src/main/java/io/delta/kernel/defaults/engine/DefaultCommitCoordinatorClientHandler.java index 38fbd7e48d..b0d2ac0c7f 100644 --- a/kernel/kernel-defaults/src/main/java/io/delta/kernel/defaults/engine/DefaultCommitCoordinatorClientHandler.java +++ b/kernel/kernel-defaults/src/main/java/io/delta/kernel/defaults/engine/DefaultCommitCoordinatorClientHandler.java @@ -95,7 +95,7 @@ public Map registerTable( // table identifier into `CommitCoordinatorClient` in all APIs. return commitCoordinatorClient.registerTable( new Path(logPath), - Optional.empty() /* table identfier */, + Optional.empty() /* table identifier */, currentVersion, StorageKernelAPIAdapter.toStorageAbstractMetadata(currentMetadata), StorageKernelAPIAdapter.toStorageAbstractProtocol(currentProtocol)); @@ -116,7 +116,7 @@ public CommitResponse commit( commitCoordinatorClient.commit( logStore, hadoopConf, - new TableDescriptor(path, Optional.empty() /* table identfier */, tableConf), + new TableDescriptor(path, Optional.empty() /* table identifier */, tableConf), commitVersion, new Iterator() { @Override @@ -150,7 +150,7 @@ public void backfillToVersion( Path path = new Path(logPath); LogStore logStore = LogStoreProvider.getLogStore(hadoopConf, path.toUri().getScheme()); TableDescriptor tableDesc = - new TableDescriptor(path, Optional.empty() /* table identfier */, tableConf); + new TableDescriptor(path, Optional.empty() /* table identifier */, tableConf); commitCoordinatorClient.backfillToVersion( logStore, hadoopConf, tableDesc, version, lastKnownBackfilledVersion); }