[Kernel] Fix typo (delta-io#3766)

sumeet-db · Oct 11, 2024 · 09fb300 · 09fb300
1 parent e6cd0ff
commit 09fb300
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/.../src/main/java/io/delta/kernel/defaults/engine/DefaultCommitCoordinatorClientHandler.java b/.../src/main/java/io/delta/kernel/defaults/engine/DefaultCommitCoordinatorClientHandler.java
@@ -95,7 +95,7 @@ public Map<String, String> 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<String>() {
                 @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);
   }