diff --git a/flink-connector/src/main/java/com/datastrato/gravitino/flink/connector/utils/FactoryUtils.java b/flink-connector/src/main/java/com/datastrato/gravitino/flink/connector/utils/FactoryUtils.java
index 84f04236f1..610005a4d3 100644
--- a/flink-connector/src/main/java/com/datastrato/gravitino/flink/connector/utils/FactoryUtils.java
+++ b/flink-connector/src/main/java/com/datastrato/gravitino/flink/connector/utils/FactoryUtils.java
@@ -22,7 +22,11 @@ private FactoryUtils() {}
 
   private static final Logger LOG = LoggerFactory.getLogger(FactoryUtils.class);
 
-  /** Utility for working with {@link Factory}s. */
+  /**
+   * Utility for working with {@link Factory}s. The {@link GravitinoCatalogFactoryHelper} override
+   * the {@link FactoryUtil.CatalogFactoryHelper#validate()} method to validate the options. For the
+   * unconsumed option keys, it logs a warning instead of throwing an exception.
+   */
   public static class GravitinoCatalogFactoryHelper extends FactoryUtil.CatalogFactoryHelper {
 
     private GravitinoCatalogFactoryHelper(
@@ -42,7 +46,10 @@ public void validate() {
     }
   }
 
-  /** Validates unconsumed option keys. */
+  /**
+   * Validates unconsumed option keys. Logs a warning for each unconsumed option key instead of
+   * throwing an exception.
+   */
   private static void ignoreUnconsumedKeys(
       String factoryIdentifier,
       Set<String> allOptionKeys,