Skip to content

Commit a6a1fb9

Browse files
committed
move
1 parent 3b415a2 commit a6a1fb9

File tree

2 files changed

+9
-11
lines changed

2 files changed

+9
-11
lines changed

fluss-common/src/main/java/org/apache/fluss/config/FlussConfigUtils.java

Lines changed: 0 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -23,10 +23,8 @@
2323
import java.lang.reflect.Field;
2424
import java.util.Collections;
2525
import java.util.HashMap;
26-
import java.util.HashSet;
2726
import java.util.List;
2827
import java.util.Map;
29-
import java.util.Set;
3028

3129
/** Utilities of Fluss {@link ConfigOptions}. */
3230
@Internal
@@ -47,14 +45,6 @@ public class FlussConfigUtils {
4745
Collections.singletonList(ConfigOptions.TABLE_DATALAKE_ENABLED.key());
4846
}
4947

50-
public static final Set<String> SENSITIVE_TABLE_OPTIONS = new HashSet<>();
51-
52-
static {
53-
SENSITIVE_TABLE_OPTIONS.add("password");
54-
SENSITIVE_TABLE_OPTIONS.add("secret");
55-
SENSITIVE_TABLE_OPTIONS.add("key");
56-
}
57-
5848
public static boolean isTableStorageConfig(String key) {
5949
return key.startsWith(TABLE_PREFIX);
6050
}

fluss-server/src/main/java/org/apache/fluss/server/coordinator/MetadataManager.java

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -62,14 +62,14 @@
6262

6363
import java.util.Collection;
6464
import java.util.HashMap;
65+
import java.util.HashSet;
6566
import java.util.Iterator;
6667
import java.util.List;
6768
import java.util.Map;
6869
import java.util.Optional;
6970
import java.util.Set;
7071
import java.util.concurrent.Callable;
7172

72-
import static org.apache.fluss.config.FlussConfigUtils.SENSITIVE_TABLE_OPTIONS;
7373
import static org.apache.fluss.server.utils.TableDescriptorValidation.validateAlterTableProperties;
7474
import static org.apache.fluss.server.utils.TableDescriptorValidation.validateTableDescriptor;
7575

@@ -83,6 +83,14 @@ public class MetadataManager {
8383
private final int maxBucketNum;
8484
private final LakeCatalogDynamicLoader lakeCatalogDynamicLoader;
8585

86+
public static final Set<String> SENSITIVE_TABLE_OPTIONS = new HashSet<>();
87+
88+
static {
89+
SENSITIVE_TABLE_OPTIONS.add("password");
90+
SENSITIVE_TABLE_OPTIONS.add("secret");
91+
SENSITIVE_TABLE_OPTIONS.add("key");
92+
}
93+
8694
/**
8795
* Creates a new metadata manager.
8896
*

0 commit comments

Comments
 (0)