Fix code typo

trinodb · Feb 4, 2025 · 94e038d · 94e038d
1 parent 3efd834
commit 94e038d
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/plugin/trino-iceberg/src/main/java/io/trino/plugin/iceberg/IcebergTableProperties.java b/plugin/trino-iceberg/src/main/java/io/trino/plugin/iceberg/IcebergTableProperties.java
@@ -253,7 +253,7 @@ private static void validateFormatVersion(int version)
         }
     }
 
-    public static int getMaxComiRetry(Map<String, Object> tableProperties)
+    public static int getMaxCommitRetry(Map<String, Object> tableProperties)
     {
         return (int) tableProperties.getOrDefault(MAX_COMMIT_RETRY, COMMIT_NUM_RETRIES_DEFAULT);
     }

diff --git a/plugin/trino-iceberg/src/main/java/io/trino/plugin/iceberg/IcebergUtil.java b/plugin/trino-iceberg/src/main/java/io/trino/plugin/iceberg/IcebergUtil.java
@@ -862,7 +862,7 @@ public static Map<String, String> createTableProperties(ConnectorTableMetadata t
         IcebergFileFormat fileFormat = IcebergTableProperties.getFileFormat(tableMetadata.getProperties());
         propertiesBuilder.put(DEFAULT_FILE_FORMAT, fileFormat.toIceberg().toString());
         propertiesBuilder.put(FORMAT_VERSION, Integer.toString(IcebergTableProperties.getFormatVersion(tableMetadata.getProperties())));
-        propertiesBuilder.put(COMMIT_NUM_RETRIES, Integer.toString(IcebergTableProperties.getMaxComiRetry(tableMetadata.getProperties())));
+        propertiesBuilder.put(COMMIT_NUM_RETRIES, Integer.toString(IcebergTableProperties.getMaxCommitRetry(tableMetadata.getProperties())));
 
         boolean objectStoreLayoutEnabled = IcebergTableProperties.getObjectStoreLayoutEnabled(tableMetadata.getProperties());
         if (objectStoreLayoutEnabled) {
-Original file line number
+Diff line change
@@ Expand Up / @@ -253,7 +253,7 @@ private static void validateFormatVersion(int version) @@
             }
         }
-        public static int getMaxComiRetry(Map<String, Object> tableProperties)
+        public static int getMaxCommitRetry(Map<String, Object> tableProperties)
         {
             return (int) tableProperties.getOrDefault(MAX_COMMIT_RETRY, COMMIT_NUM_RETRIES_DEFAULT);
         }
@@ Expand Down @@