(fluss) branch main updated: fix typo in metadata manage (#2159)

[yunhong]

This is an automated email from the ASF dual-hosted git repository.

yunhong pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/fluss.git


The following commit(s) were added to refs/heads/main by this push:
     new 49ce39d7a fix typo in metadata manage (#2159)
49ce39d7a is described below

commit 49ce39d7ab8cd38ec7f079746d2f6a92696cdce7
Author: Kerwin <37063904+zhuangch...@users.noreply.github.com>
AuthorDate: Fri Dec 12 15:11:20 2025 +0800

    fix typo in metadata manage (#2159)
---
 .../org/apache/fluss/server/coordinator/MetadataManager.java   | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

diff --git 
a/fluss-server/src/main/java/org/apache/fluss/server/coordinator/MetadataManager.java
 
b/fluss-server/src/main/java/org/apache/fluss/server/coordinator/MetadataManager.java
index d62f50528..a2fc6cf3d 100644
--- 
a/fluss-server/src/main/java/org/apache/fluss/server/coordinator/MetadataManager.java
+++ 
b/fluss-server/src/main/java/org/apache/fluss/server/coordinator/MetadataManager.java
@@ -83,12 +83,12 @@ public class MetadataManager {
     private final int maxBucketNum;
     private final LakeCatalogDynamicLoader lakeCatalogDynamicLoader;
 
-    public static final Set<String> SENSITIVE_TABLE_OPTIOINS = new HashSet<>();
+    public static final Set<String> SENSITIVE_TABLE_OPTIONS = new HashSet<>();
 
     static {
-        SENSITIVE_TABLE_OPTIOINS.add("password");
-        SENSITIVE_TABLE_OPTIOINS.add("secret");
-        SENSITIVE_TABLE_OPTIOINS.add("key");
+        SENSITIVE_TABLE_OPTIONS.add("password");
+        SENSITIVE_TABLE_OPTIONS.add("secret");
+        SENSITIVE_TABLE_OPTIONS.add("key");
     }
 
     /**
@@ -550,7 +550,7 @@ public class MetadataManager {
         Iterator<Map.Entry<String, String>> iterator = 
tableLakeOptions.entrySet().iterator();
         while (iterator.hasNext()) {
             String key = iterator.next().getKey().toLowerCase();
-            if (SENSITIVE_TABLE_OPTIOINS.stream().anyMatch(key::contains)) {
+            if (SENSITIVE_TABLE_OPTIONS.stream().anyMatch(key::contains)) {
                 iterator.remove();
             }
         }